public class ZMQQueue
extends java.lang.Object
implements java.lang.Runnable
| Modifier and Type | Field and Description |
|---|---|
private ZMQ.Socket |
inSocket |
private ZMQ.Socket |
outSocket |
| Constructor and Description |
|---|
ZMQQueue(ZMQ.Context context,
ZMQ.Socket inSocket,
ZMQ.Socket outSocket)
Class constructor.
|
| Modifier and Type | Method and Description |
|---|---|
void |
run() |
private final ZMQ.Socket inSocket
private final ZMQ.Socket outSocket
public ZMQQueue(ZMQ.Context context, ZMQ.Socket inSocket, ZMQ.Socket outSocket)
context - a 0MQ context previously created.inSocket - input socketoutSocket - output socket