class EventSourceTopology implements EventAggregatorService, EventSourceRegistry {

    @Override
    public void close() {
        aggregatorRpcReg.close();
        eventSourceTopicMap.values().forEach(EventSourceTopic::close);
    }

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

}