RunnableZMQStreamerpublic class ZMQForwarder extends Object implements Runnable
| Constructor | Description |
|---|---|
ZMQForwarder(ZMQ.Context context,
ZMQ.Socket inSocket,
ZMQ.Socket outSocket) |
Class constructor.
|
public ZMQForwarder(ZMQ.Context context, ZMQ.Socket inSocket, ZMQ.Socket outSocket)
context - a 0MQ context previously created.inSocket - input socketoutSocket - output socket