public class ZDispatcher extends Object
Modifier and Type | Class and Description |
---|---|
static interface |
ZDispatcher.ZMessageHandler |
static class |
ZDispatcher.ZSender |
Constructor and Description |
---|
ZDispatcher() |
ZDispatcher(ExecutorService dispatcherExecutor) |
Modifier and Type | Method and Description |
---|---|
void |
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) |
public ZDispatcher()
public ZDispatcher(ExecutorService dispatcherExecutor)
public void registerHandler(ZMQ.Socket socket, ZDispatcher.ZMessageHandler messageHandler, ZDispatcher.ZSender sender)
public void registerHandler(ZMQ.Socket socket, ZDispatcher.ZMessageHandler messageHandler, ZDispatcher.ZSender sender, ExecutorService threadpool)
public void unregisterHandler(ZMQ.Socket socket)
public void shutdown()