- RendererServiceOperations rendererServiceOperations = new RendererServiceOperationsImpl(deviceRendererService,
- otnDeviceRendererService, olmPowerServiceRpc, lightyServices.getBindingDataBroker(),
- lightyServices.getBindingNotificationPublishService());
- servicehandlerProvider = new ServicehandlerProvider(lightyServices.getBindingDataBroker(),
- lightyServices.getRpcProviderService(), lightyServices.getNotificationService(), pathComputationService,
- rendererServiceOperations, lightyServices.getBindingNotificationPublishService());
- tapiProvider = initTapi(lightyServices, rendererServiceOperations, pathComputationService);
+ RendererServiceOperations rendererServiceOperations = new RendererServiceOperationsImpl(
+ deviceRendererService, otnDeviceRendererService, olmPowerServiceRpc,
+ lgServBDB,
+ lgServBNPS,
+ portMapping);
+ ServiceDataStoreOperations serviceDataStoreOperations =
+ new ServiceDataStoreOperationsImpl(lgServBDB);
+ RendererListenerImpl rendererListenerImpl =
+ new RendererListenerImpl(pathComputationService, lgServBNPS, networkModelService);
+ PceListenerImpl pceListenerImpl = new PceListenerImpl(
+ rendererServiceOperations, pathComputationService,
+ lgServBNPS, serviceDataStoreOperations);
+ NetworkModelListenerImpl networkModelListenerImpl = new NetworkModelListenerImpl(
+ lgServBNPS, serviceDataStoreOperations);
+ ServicehandlerImpl servicehandler = new ServicehandlerImpl(lgServRPS,
+ pathComputationService, rendererServiceOperations,
+ lgServBNPS, pceListenerImpl,
+ rendererListenerImpl, networkModelListenerImpl, serviceDataStoreOperations,
+ new CatalogDataStoreOperationsImpl(networkTransaction));
+ rpcRegistrations.add(servicehandler.getRegisteredRpc());
+ servicehandlerProvider = new ServicehandlerProvider(
+ lgServBDB,
+ lgServNS, serviceDataStoreOperations, pceListenerImpl,
+ rendererListenerImpl, networkModelListenerImpl, lgServBNPS,
+ servicehandler,
+ 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 TapiNetworkModelListenerImpl(
+ networkTransaction, lgServBNPS),
+ tapiLink,
+ new TapiNetworkModelServiceImpl(
+ networkTransaction, deviceTransactionManager, tapiLink,
+ lgServBNPS));
+ rpcRegistrations.addAll(tapiProvider.getRegisteredRpcs());
+ }
+ if (activateNbiNotification) {
+ LOG.info("Creating nbi-notifications beans ...");
+ nbiNotificationsProvider = new NbiNotificationsProvider(
+ lgServRPS, lgServNS,
+ lightyServices.getAdapterContext().currentSerializer(),
+ networkTransaction, null);
+ }