Package dev.getelements.elements.rt.remote.jeromq

Class JeroMQMultiplexRouter

java.lang.Object

dev.getelements.elements.rt.remote.jeromq.JeroMQMultiplexRouter

public class JeroMQMultiplexRouter
extends Object

Constructor Summary

Constructors

Constructor	Description
JeroMQMultiplexRouter(InstanceId instanceId, org.zeromq.ZContext zContext, org.zeromq.ZMQ.Poller poller)

Method Summary

Modifier and Type	Method	Description
void	closeRoutesViaInstance(InstanceId instanceId, String instanceConnectAddress)
String	getLocalBindAddress(NodeId nodeId, JeroMQInstanceConnectionId connectionId)
com.google.common.collect.SortedSetMultimap<NodeId,JeroMQInstanceConnectionId>	getRoutingTable()
void	log()
String	openRouteToNode(NodeId nodeId, String instanceConnectAddress)
void	poll()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

JeroMQMultiplexRouter

public JeroMQMultiplexRouter(InstanceId instanceId,
 org.zeromq.ZContext zContext,
 org.zeromq.ZMQ.Poller poller)

Method Details

poll

public void poll()

openRouteToNode

public String openRouteToNode(NodeId nodeId,
 String instanceConnectAddress)

closeRoutesViaInstance

public void closeRoutesViaInstance(InstanceId instanceId,
 String instanceConnectAddress)

getLocalBindAddress

public String getLocalBindAddress(NodeId nodeId,
 JeroMQInstanceConnectionId connectionId)

log

public void log()

getRoutingTable

public com.google.common.collect.SortedSetMultimap<NodeId,JeroMQInstanceConnectionId> getRoutingTable()