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

Class JeroMQDemultiplexRouter

java.lang.Object

dev.getelements.elements.rt.remote.jeromq.JeroMQDemultiplexRouter

public class JeroMQDemultiplexRouter
extends Object

Constructor Summary

Constructors

Constructor	Description
JeroMQDemultiplexRouter(InstanceId instanceId, org.zeromq.ZContext zContext, org.zeromq.ZMQ.Poller poller, org.zeromq.ZMQ.PollItem frontend)

Method Summary

Modifier and Type	Method	Description
void	closeBindingForNode(NodeId nodeId)
void	forward(org.zeromq.ZMsg zMsg, org.zeromq.ZMsg identity)
Collection<NodeId>	getConnectedNodeIds()
String	getLocalBindAddress(NodeId nodeId)
void	log()
String	openBinding(NodeId nodeId)
void	poll()

Methods inherited from class java.lang.Object

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

Constructor Details

JeroMQDemultiplexRouter

public JeroMQDemultiplexRouter(InstanceId instanceId,
 org.zeromq.ZContext zContext,
 org.zeromq.ZMQ.Poller poller,
 org.zeromq.ZMQ.PollItem frontend)

Method Details

poll

public void poll()

openBinding

public String openBinding(NodeId nodeId)

closeBindingForNode

public void closeBindingForNode(NodeId nodeId)

forward

public void forward(org.zeromq.ZMsg zMsg,
 org.zeromq.ZMsg identity)

getConnectedNodeIds

public Collection<NodeId> getConnectedNodeIds()

getLocalBindAddress

public String getLocalBindAddress(NodeId nodeId)

log

public void log()