opendaylight/md-sal/sal-remoterpc-connector/src/main/java/org/opendaylight/controller/remote/rpc/RemoteRpcImplementation.java

   1 package org.opendaylight.controller.remote.rpc;
   2
   3 import static akka.pattern.Patterns.ask;
   4
   5 import akka.actor.ActorRef;
   6 import com.google.common.util.concurrent.CheckedFuture;
   7 import org.opendaylight.controller.md.sal.dom.api.DOMRpcException;
   8 import org.opendaylight.controller.md.sal.dom.api.DOMRpcIdentifier;
   9 import org.opendaylight.controller.md.sal.dom.api.DOMRpcImplementation;
  10 import org.opendaylight.controller.md.sal.dom.api.DOMRpcResult;
  11 import org.opendaylight.controller.remote.rpc.messages.InvokeRpc;
  12 import org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode;
  13
  14 public class RemoteRpcImplementation implements DOMRpcImplementation {
  15     private final ActorRef rpcBroker;
  16     private final RemoteRpcProviderConfig config;
  17
  18     public RemoteRpcImplementation(final ActorRef rpcBroker, final RemoteRpcProviderConfig config) {
  19         this.rpcBroker = rpcBroker;
  20         this.config = config;
  21     }
  22
  23     @Override
  24     public CheckedFuture<DOMRpcResult, DOMRpcException> invokeRpc(final DOMRpcIdentifier rpc, final NormalizedNode<?, ?> input) {
  25         final InvokeRpc rpcMsg = new InvokeRpc(rpc.getType().getLastComponent(), rpc.getContextReference(), input);
  26         final scala.concurrent.Future<Object> future = ask(rpcBroker, rpcMsg, config.getAskDuration());
  27         return RemoteDOMRpcFuture.from(future);
  28     }
  29 }