Package org.zeromq
Class ZDispatcher
- java.lang.Object
-
- org.zeromq.ZDispatcher
-
public class ZDispatcher extends Object
Dispatcher for ZeroMQ Sockets. Warning: The Dispatcher uses a busy spin loop when waiting on events. This is ideal for low latency applications but not in all situations. It has the side effect of consuming 100% of a CPU when waiting for events. With this dispatcher, you can register ONE handler per socket and get a Sender for sending ZMsg.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static interfaceZDispatcher.ZMessageHandlerstatic classZDispatcher.ZSender
-
Constructor Summary
Constructors Constructor Description ZDispatcher()ZDispatcher(ExecutorService dispatcherExecutor)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidregisterHandler(ZMQ.Socket socket, ZDispatcher.ZMessageHandler messageHandler, ZDispatcher.ZSender sender)voidregisterHandler(ZMQ.Socket socket, ZDispatcher.ZMessageHandler messageHandler, ZDispatcher.ZSender sender, ExecutorService threadpool)voidshutdown()voidunregisterHandler(ZMQ.Socket socket)
-
-
-
Constructor Detail
-
ZDispatcher
public ZDispatcher()
-
ZDispatcher
public ZDispatcher(ExecutorService dispatcherExecutor)
-
-
Method Detail
-
registerHandler
public void registerHandler(ZMQ.Socket socket, ZDispatcher.ZMessageHandler messageHandler, ZDispatcher.ZSender sender)
-
registerHandler
public void registerHandler(ZMQ.Socket socket, ZDispatcher.ZMessageHandler messageHandler, ZDispatcher.ZSender sender, ExecutorService threadpool)
-
unregisterHandler
public void unregisterHandler(ZMQ.Socket socket)
-
shutdown
public void shutdown()
-
-