X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=olm%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Ftransportpce%2Folm%2FOlmProvider.java;h=db2865167ea053f03ff0185692c4b163ccfe77dc;hb=a8cbc775799b33a13f563f073c287fddc9f51000;hp=b283ef561ec2fcaaa472d99edb58e706686691b3;hpb=82610815f1b706e2f9b5e5578474f3a8205c41aa;p=transportpce.git diff --git a/olm/src/main/java/org/opendaylight/transportpce/olm/OlmProvider.java b/olm/src/main/java/org/opendaylight/transportpce/olm/OlmProvider.java index b283ef561..db2865167 100644 --- a/olm/src/main/java/org/opendaylight/transportpce/olm/OlmProvider.java +++ b/olm/src/main/java/org/opendaylight/transportpce/olm/OlmProvider.java @@ -8,10 +8,10 @@ package org.opendaylight.transportpce.olm; -import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.RpcRegistration; -import org.opendaylight.controller.sal.binding.api.RpcProviderRegistry; +import org.opendaylight.mdsal.binding.api.RpcProviderService; import org.opendaylight.transportpce.olm.service.OlmPowerService; -import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev170418.TransportpceOlmService; +import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev210618.TransportpceOlmService; +import org.opendaylight.yangtools.concepts.ObjectRegistration; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -20,19 +20,19 @@ import org.slf4j.LoggerFactory; */ public class OlmProvider { private static final Logger LOG = LoggerFactory.getLogger(OlmProvider.class); - private final RpcProviderRegistry rpcProviderRegistry; + private final RpcProviderService rpcProviderService; private final OlmPowerService olmPowerService; - private RpcRegistration olmRPCRegistration; + private ObjectRegistration olmRPCRegistration; /** * Instantiates a new olm provider. * @param olmPowerService * implementation of OlmService - * @param rpcProviderRegistry - * the rpc provider registry + * @param rpcProviderService + * the rpc provider service */ - public OlmProvider(final RpcProviderRegistry rpcProviderRegistry, final OlmPowerService olmPowerService) { - this.rpcProviderRegistry = rpcProviderRegistry; + public OlmProvider(final RpcProviderService rpcProviderService, final OlmPowerService olmPowerService) { + this.rpcProviderService = rpcProviderService; this.olmPowerService = olmPowerService; } @@ -42,7 +42,7 @@ public class OlmProvider { public void init() { LOG.info("OlmProvider Session Initiated"); // Initializing Notification module - olmRPCRegistration = rpcProviderRegistry.addRpcImplementation(TransportpceOlmService.class, + olmRPCRegistration = rpcProviderService.registerRpcImplementation(TransportpceOlmService.class, new OlmPowerServiceRpcImpl(this.olmPowerService)); } @@ -50,10 +50,10 @@ public class OlmProvider { * Method called when the blueprint container is destroyed. */ public void close() { - LOG.info("RendererProvider Closed"); + LOG.info("OlmProvider Closed"); // Clean up the RPC service registration if (olmRPCRegistration != null) { olmRPCRegistration.close(); } } -} \ No newline at end of file +}