X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-remoterpc-connector%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fremote%2Frpc%2FRemoteRpcProviderFactory.java;h=d17242ed6048f51638d11612db130c2d62f33961;hp=c82a72eaa56c82e40388b8fb612eed7b198dbae8;hb=86024f5f5c072e38b51e8367226ad166e3f42d0f;hpb=05a8052a457b2e53f06233f1a0b056d162118566 diff --git a/opendaylight/md-sal/sal-remoterpc-connector/src/main/java/org/opendaylight/controller/remote/rpc/RemoteRpcProviderFactory.java b/opendaylight/md-sal/sal-remoterpc-connector/src/main/java/org/opendaylight/controller/remote/rpc/RemoteRpcProviderFactory.java index c82a72eaa5..d17242ed60 100644 --- a/opendaylight/md-sal/sal-remoterpc-connector/src/main/java/org/opendaylight/controller/remote/rpc/RemoteRpcProviderFactory.java +++ b/opendaylight/md-sal/sal-remoterpc-connector/src/main/java/org/opendaylight/controller/remote/rpc/RemoteRpcProviderFactory.java @@ -11,8 +11,8 @@ package org.opendaylight.controller.remote.rpc; import akka.actor.ActorSystem; import akka.osgi.BundleDelegatingClassLoader; import com.typesafe.config.Config; +import org.opendaylight.controller.md.sal.dom.api.DOMRpcProviderService; import org.opendaylight.controller.sal.core.api.Broker; -import org.opendaylight.controller.sal.core.api.RpcProvisionRegistry; import org.osgi.framework.BundleContext; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -23,21 +23,21 @@ public class RemoteRpcProviderFactory { public static RemoteRpcProvider createInstance( final Broker broker, final BundleContext bundleContext, final RemoteRpcProviderConfig config){ - RemoteRpcProvider rpcProvider = - new RemoteRpcProvider(createActorSystem(bundleContext, config), (RpcProvisionRegistry) broker); + final RemoteRpcProvider rpcProvider = + new RemoteRpcProvider(createActorSystem(bundleContext, config), (DOMRpcProviderService) broker); broker.registerProvider(rpcProvider); return rpcProvider; } - private static ActorSystem createActorSystem(BundleContext bundleContext, RemoteRpcProviderConfig config){ + private static ActorSystem createActorSystem(final BundleContext bundleContext, final RemoteRpcProviderConfig config){ // Create an OSGi bundle classloader for actor system - BundleDelegatingClassLoader classLoader = + final BundleDelegatingClassLoader classLoader = new BundleDelegatingClassLoader(bundleContext.getBundle(), Thread.currentThread().getContextClassLoader()); - Config actorSystemConfig = config.get(); + final Config actorSystemConfig = config.get(); if(LOG.isDebugEnabled()) { LOG.debug("Actor system configuration\n{}", actorSystemConfig.root().render()); }