opendaylight/md-sal/sal-connector-api/src/main/java/org/opendaylight/controller/sal/connector/api/BindingAwareZeroMqRpcRouter.java

   1 package org.opendaylight.controller.sal.connector.api;
   2
   3 import java.util.concurrent.Future;
   4
   5 public class BindingAwareZeroMqRpcRouter implements BindingAwareRpcRouter {
   6
   7     BindingAwareRpcRouter mdSalRouter;
   8
   9     public BindingAwareRpcRouter getMdSalRouter() {
  10         return mdSalRouter;
  11     }
  12
  13
  14     public void setMdSalRouter(BindingAwareRpcRouter mdSalRouter) {
  15         this.mdSalRouter = mdSalRouter;
  16     }
  17
  18
  19     @Override
  20     public Future<RpcReply<byte[]>> sendRpc(RpcRequest<String, String, String, byte[]> input) {
  21         // Write message down to the wire
  22         return null;
  23     }
  24
  25     // Receiver part - invoked when request is received and deserialized
  26     private Future<RpcReply<byte[]>> receivedRequest(RpcRequest<String, String, String, byte[]> input) {
  27
  28         return mdSalRouter.sendRpc(input);
  29     }
  30
  31 }