- RendererServiceOperations rendererServiceOperations = new RendererServiceOperationsImpl(deviceRendererService,
- otnDeviceRendererService, olmPowerServiceRpc, lightyServices.getBindingDataBroker(),
- lightyServices.getBindingNotificationPublishService());
- ServiceDataStoreOperations serviceDataStoreOperations = new ServiceDataStoreOperationsImpl(
- lightyServices.getBindingDataBroker());
- RendererListenerImpl rendererListenerImpl = new RendererListenerImpl(pathComputationService,
- lightyServices.getBindingNotificationPublishService());
- PceListenerImpl pceListenerImpl = new PceListenerImpl(rendererServiceOperations, pathComputationService,
- lightyServices.getBindingNotificationPublishService(), serviceDataStoreOperations);
- NetworkModelListenerImpl networkModelListenerImpl = new NetworkModelListenerImpl(
- lightyServices.getBindingNotificationPublishService(), serviceDataStoreOperations);
- ServicehandlerImpl servicehandler = new ServicehandlerImpl(lightyServices.getBindingDataBroker(),
- pathComputationService, rendererServiceOperations, lightyServices.getBindingNotificationPublishService(),
- pceListenerImpl, rendererListenerImpl, networkModelListenerImpl, serviceDataStoreOperations, "N/A");
- servicehandlerProvider = new ServicehandlerProvider(lightyServices.getBindingDataBroker(),
- lightyServices.getRpcProviderService(), lightyServices.getNotificationService(),
- serviceDataStoreOperations, pceListenerImpl, rendererListenerImpl, networkModelListenerImpl,
- servicehandler);
-
- tapiProvider = initTapi(lightyServices, servicehandler, networkTransaction);
- if(activateNbiNotification) {
+ RendererServiceOperations rendererServiceOperations = new RendererServiceOperationsImpl(
+ deviceRendererService, otnDeviceRendererService, olmPowerServiceRpc,
+ lgServBDB,
+ lgServBNPS,
+ portMapping);
+ ServiceDataStoreOperations serviceDataStoreOperations =
+ new ServiceDataStoreOperationsImpl(lgServBDB);
+ RendererNotificationHandler rendererNotificationHandler =
+ new RendererNotificationHandler(pathComputationService, lgServBNPS, networkModelService);
+ PceNotificationHandler pceListenerImpl = new PceNotificationHandler(
+ rendererServiceOperations, pathComputationService,
+ lgServBNPS, serviceDataStoreOperations);
+ NetworkModelNotificationHandler networkModelNotificationHandler = new NetworkModelNotificationHandler(
+ lgServBNPS, serviceDataStoreOperations);
+ ServicehandlerImpl servicehandler = new ServicehandlerImpl(lgServRPS,
+ pathComputationService, rendererServiceOperations,
+ lgServBNPS, pceListenerImpl,
+ rendererNotificationHandler, networkModelNotificationHandler, serviceDataStoreOperations,
+ new CatalogDataStoreOperationsImpl(networkTransaction));
+ rpcRegistrations.add(servicehandler.getRegisteredRpc());
+ servicehandlerProvider = new ServiceHandlerProvider(
+ lgServBDB,
+ lgServNS, serviceDataStoreOperations, pceListenerImpl,
+ rendererNotificationHandler, networkModelNotificationHandler,
+ new ServiceListener(
+ servicehandler, serviceDataStoreOperations, lgServBNPS));
+ if (activateTapi) {
+ LOG.info("Creating tapi beans ...");
+ TapiLink tapiLink = new TapiLinkImpl(networkTransaction);
+ new TapiNetworkUtilsImpl(lgServRPS, networkTransaction, tapiLink);
+ tapiProvider = initTapi(
+ lightyServices, servicehandler, networkTransaction, serviceDataStoreOperations,
+ new TapiNetworkModelNotificationHandler(
+ networkTransaction, lgServBNPS),
+ tapiLink,
+ new TapiNetworkModelServiceImpl(
+ networkTransaction, deviceTransactionManager, tapiLink,
+ lgServBNPS));
+ rpcRegistrations.addAll(tapiProvider.getRegisteredRpcs());
+ }
+ if (activateNbiNotification) {