Broker broker = getDomBrokerDependency();
-
-
final int port = getPort() != null ? getPort() : ZEROMQ_ROUTER_PORT;
ServerImpl serverImpl = new ServerImpl(port);
RoutingTableProvider provider = new RoutingTableProvider(bundleContext,serverImpl);
-
RemoteRpcProvider facade = new RemoteRpcProvider(serverImpl, clientImpl);
facade.setRoutingTableProvider(provider );