Package org.zeromq
Class ZDispatcher
java.lang.Object
org.zeromq.ZDispatcher
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 ClassesModifier and TypeClassDescriptionstatic interface
static final class
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoid
registerHandler
(ZMQ.Socket socket, ZDispatcher.ZMessageHandler messageHandler, ZDispatcher.ZSender sender) void
registerHandler
(ZMQ.Socket socket, ZDispatcher.ZMessageHandler messageHandler, ZDispatcher.ZSender sender, ExecutorService threadpool) void
shutdown()
void
unregisterHandler
(ZMQ.Socket socket)
-
Constructor Details
-
ZDispatcher
public ZDispatcher() -
ZDispatcher
-
-
Method Details
-
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
-
shutdown
public void shutdown()
-