+ 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;