class EventSourceTopology implements EventAggregatorService, EventSourceRegistry {

    public void register(final EventSource eventSource) {
        final NodeKey nodeKey = eventSource.getSourceNodeKey();
        final KeyedInstanceIdentifier<Node, NodeKey> sourcePath = EVENT_SOURCE_TOPOLOGY_PATH.child(Node.class, nodeKey);
        final Registration reg = rpcRegistry.registerRpcImplementation(EventSourceService.class, eventSource,
            Collections.singleton(sourcePath));
        routedRpcRegistrations.put(nodeKey, reg);
        insert(sourcePath);
    }

    public  EventSourceTopology(final DataBroker dataBroker, final RpcProviderService providerService,
            RpcConsumerRegistry rpcService);

}