1 package org.opendaylight.controller.sal.connector.api;
3 import java.util.concurrent.Future;
5 public class BindingAwareZeroMqRpcRouter implements BindingAwareRpcRouter {
7 BindingAwareRpcRouter mdSalRouter;
9 public BindingAwareRpcRouter getMdSalRouter() {
14 public void setMdSalRouter(BindingAwareRpcRouter mdSalRouter) {
15 this.mdSalRouter = mdSalRouter;
20 public Future<RpcReply<byte[]>> sendRpc(RpcRequest<String, String, String, byte[]> input) {
21 // Write message down to the wire
25 // Receiver part - invoked when request is received and deserialized
26 private Future<RpcReply<byte[]>> receivedRequest(RpcRequest<String, String, String, byte[]> input) {
28 return mdSalRouter.sendRpc(input);