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=226faf22dcced063a49fb28a691a0095fc789c6f;hp=0e6b795c058877069640a848fe1144575db37443;hb=c55d6cccb33e3de942e521e31404a60c1738b768;hpb=b10d77375b5a290143106180f1583ea4e18f8478 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 0e6b795c05..226faf22dc 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 @@ -1,5 +1,5 @@ /* - * Copyright (c) 2014 Cisco Systems, Inc. and others. All rights reserved. + * Copyright (c) 2015 Cisco Systems, Inc. and others. All rights reserved. * * This program and the accompanying materials are made available under the * terms of the Eclipse Public License v1.0 which accompanies this distribution, @@ -8,19 +8,14 @@ package org.opendaylight.controller.remote.rpc; - -import org.opendaylight.controller.remote.rpc.utils.DefaultAkkaConfigurationReader; -import org.opendaylight.controller.sal.core.api.Broker; -import org.opendaylight.controller.sal.core.api.RpcProvisionRegistry; -import org.osgi.framework.BundleContext; +import akka.actor.ActorSystem; +import org.opendaylight.controller.md.sal.dom.api.DOMRpcProviderService; +import org.opendaylight.controller.md.sal.dom.api.DOMRpcService; public class RemoteRpcProviderFactory { - public static RemoteRpcProvider createInstance(final Broker broker, final BundleContext bundleContext){ + public static RemoteRpcProvider createInstance(final DOMRpcProviderService rpcProviderService, + final DOMRpcService rpcService, final ActorSystem actorSystem, final RemoteRpcProviderConfig config) { - ActorSystemFactory.createInstance(bundleContext, new DefaultAkkaConfigurationReader()); - RemoteRpcProvider rpcProvider = - new RemoteRpcProvider(ActorSystemFactory.getInstance(), (RpcProvisionRegistry) broker); - broker.registerProvider(rpcProvider); - return rpcProvider; + return new RemoteRpcProvider(actorSystem, rpcProviderService, rpcService, config); } }