X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=pce%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Ftransportpce%2Fpce%2Fimpl%2FPceProvider.java;h=bab1554114ad7fe1e80d1f2f4e90311a3a6464d6;hb=4bb3743a3214fb481e4cc147914a314c9ff6d1c3;hp=9b25b17916cefabb61d4ea0340fe7f482fd7bf7d;hpb=4378fca1d31d1f75c0480c752aa711fb885e6135;p=transportpce.git diff --git a/pce/src/main/java/org/opendaylight/transportpce/pce/impl/PceProvider.java b/pce/src/main/java/org/opendaylight/transportpce/pce/impl/PceProvider.java index 9b25b1791..bab155411 100644 --- a/pce/src/main/java/org/opendaylight/transportpce/pce/impl/PceProvider.java +++ b/pce/src/main/java/org/opendaylight/transportpce/pce/impl/PceProvider.java @@ -9,8 +9,12 @@ package org.opendaylight.transportpce.pce.impl; import org.opendaylight.mdsal.binding.api.RpcProviderService; import org.opendaylight.transportpce.pce.service.PathComputationService; -import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.pce.rev200128.TransportpcePceService; +import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.pce.rev220808.TransportpcePceService; import org.opendaylight.yangtools.concepts.ObjectRegistration; +import org.osgi.service.component.annotations.Activate; +import org.osgi.service.component.annotations.Component; +import org.osgi.service.component.annotations.Deactivate; +import org.osgi.service.component.annotations.Reference; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -18,23 +22,18 @@ import org.slf4j.LoggerFactory; * Class to register * Pce Service & Notification. */ +@Component public class PceProvider { private static final Logger LOG = LoggerFactory.getLogger(PceProvider.class); private final RpcProviderService rpcService; - private final PathComputationService pathComputationService; private ObjectRegistration rpcRegistration; - public PceProvider(RpcProviderService rpcProviderService, PathComputationService pathComputationService) { + @Activate + public PceProvider(@Reference RpcProviderService rpcProviderService, + @Reference PathComputationService pathComputationService) { this.rpcService = rpcProviderService; - this.pathComputationService = pathComputationService; - } - - /* - * Method called when the blueprint container is created. - */ - public void init() { LOG.info("PceProvider Session Initiated"); final PceServiceRPCImpl consumer = new PceServiceRPCImpl(pathComputationService); rpcRegistration = rpcService.registerRpcImplementation(TransportpcePceService.class, consumer); @@ -43,9 +42,9 @@ public class PceProvider { /* * Method called when the blueprint container is destroyed. */ + @Deactivate public void close() { LOG.info("PceProvider Closed"); rpcRegistration.close(); } - }