import org.opendaylight.transportpce.olm.power.PowerMgmtImpl;
import org.opendaylight.transportpce.olm.service.OlmPowerServiceImpl;
import org.opendaylight.transportpce.pce.gnpy.consumer.GnpyConsumerImpl;
-import org.opendaylight.transportpce.pce.impl.PceProvider;
import org.opendaylight.transportpce.pce.impl.PceServiceRPCImpl;
import org.opendaylight.transportpce.pce.service.PathComputationService;
import org.opendaylight.transportpce.pce.service.PathComputationServiceImpl;
// because implementation has additional public methods ...
private final DeviceTransactionManagerImpl deviceTransactionManager;
private final NetworkTransactionService networkTransaction;
- // pce beans
- private final PceProvider pceProvider;
// network model beans
private final NetworkModelProvider networkModelProvider;
// service-handler beans
new GnpyConsumerImpl(
"http://127.0.0.1:8008", "gnpy", "gnpy", lightyServices.getAdapterContext().currentSerializer()),
portMapping);
- pceProvider = new PceProvider(lgServRPS, pathComputationService, new PceServiceRPCImpl(pathComputationService));
-
+ rpcRegistrations.add(
+ new PceServiceRPCImpl(lgServRPS, pathComputationService)
+ .getRegisteredRpc());
LOG.info("Creating OLM beans ...");
MappingUtils mappingUtils = new MappingUtilsImpl(lgServBDB);
CrossConnect crossConnect = initCrossConnect(mappingUtils);
lgServBNPS, serviceDataStoreOperations);
NetworkModelListenerImpl networkModelListenerImpl = new NetworkModelListenerImpl(
lgServBNPS, serviceDataStoreOperations);
- OrgOpenroadmServiceService servicehandler = new ServicehandlerImpl(
+ ServicehandlerImpl servicehandler = new ServicehandlerImpl(lgServRPS,
pathComputationService, rendererServiceOperations,
lgServBNPS, pceListenerImpl,
rendererListenerImpl, networkModelListenerImpl, serviceDataStoreOperations,
new CatalogDataStoreOperationsImpl(networkTransaction));
+ rpcRegistrations.add(servicehandler.getRegisteredRpc());
servicehandlerProvider = new ServicehandlerProvider(
- lgServBDB, lgServRPS,
+ lgServBDB,
lgServNS, serviceDataStoreOperations, pceListenerImpl,
rendererListenerImpl, networkModelListenerImpl, lgServBNPS,
servicehandler,
if (activateTapi) {
LOG.info("Creating tapi beans ...");
TapiLink tapiLink = new TapiLinkImpl(networkTransaction);
- new TapiNetworkUtilsImpl(networkTransaction, tapiLink);
+ new TapiNetworkUtilsImpl(lgServRPS, networkTransaction, tapiLink);
tapiProvider = initTapi(
lightyServices, servicehandler, networkTransaction, serviceDataStoreOperations,
new TapiNetworkModelListenerImpl(
new TapiNetworkModelServiceImpl(
networkTransaction, deviceTransactionManager, tapiLink,
lgServBNPS));
+ rpcRegistrations.addAll(tapiProvider.getRegisteredRpcs());
}
if (activateNbiNotification) {
LOG.info("Creating nbi-notifications beans ...");
nbiNotificationsProvider = new NbiNotificationsProvider(
- null, null, lgServRPS,
- lgServNS, lightyServices.getAdapterContext().currentSerializer(),
- networkTransaction);
+ lgServRPS, lgServNS,
+ lightyServices.getAdapterContext().currentSerializer(),
+ networkTransaction, null);
}
}
servicehandlerProvider.close();
LOG.info("Shutting down network-model provider ...");
networkModelProvider.close();
- LOG.info("Shutting down PCE provider ...");
- pceProvider.close();
LOG.info("Shutting down transaction providers ...");
deviceTransactionManager.preDestroy();
LOG.info("Closing registered RPCs...");
lightyServices.getBindingDataBroker(), lightyServices.getRpcProviderService(),
lightyServices.getNotificationService(), lightyServices.getBindingNotificationPublishService(),
networkTransactionService, servicehandler, serviceDataStoreOperations,
- new TapiNetworkUtilsImpl(networkTransactionService, tapiLink),
tapiNetworkModelListenerImpl, tapiNetworkModelService);
}