- final Providers.BindingAware bap = new Providers.BindingAware(ic);
- final Providers.BindingIndependent bip = new Providers.BindingIndependent(ic);
+ final ProviderContext bindingCtx = getBindingBrokerDependency().registerProvider(new Providers.BindingAware());
+ final ProviderSession domCtx = getDomBrokerDependency().registerProvider(new Providers.BindingIndependent());
+ final DataBroker dataBroker = bindingCtx.getSALService(DataBroker.class);
+ final DOMNotificationPublishService domPublish = domCtx.getService(DOMNotificationPublishService.class);
+ final DOMMountPointService domMount = domCtx.getService(DOMMountPointService.class);
+ final RpcProviderRegistry rpcRegistry = bindingCtx.getSALService(RpcProviderRegistry.class);
+ final MountPointService mountPointService = bindingCtx.getSALService(MountPointService.class);
+ final EventSourceRegistryWrapper eventSourceRegistryWrapper = new EventSourceRegistryWrapper(new EventSourceTopology(dataBroker, rpcRegistry));
+// final NetconfEventSourceManager netconfEventSourceManager
+// = NetconfEventSourceManager.create(dataBroker,
+// domPublish,
+// domMount,
+// mountPointService,
+// eventSourceRegistryWrapper,
+// getNamespaceToStream());
+// eventSourceRegistryWrapper.addAutoCloseable(netconfEventSourceManager);
+ LOGGER.info("Messagebus initialized");
+ return eventSourceRegistryWrapper;