Package org.zeromq
Class ZMQQueue
- java.lang.Object
-
- org.zeromq.ZMQQueue
-
-
Constructor Summary
Constructors Constructor Description ZMQQueue(ZMQ.Context context, ZMQ.Socket inSocket, ZMQ.Socket outSocket)
Class constructor.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
Unregisters input and output sockets.void
run()
Queuing of requests and replies.
-
-
-
Constructor Detail
-
ZMQQueue
public ZMQQueue(ZMQ.Context context, ZMQ.Socket inSocket, ZMQ.Socket outSocket)
Class constructor.- Parameters:
context
- a 0MQ context previously created.inSocket
- input socketoutSocket
- output socket
-
-
Method Detail
-
close
public void close() throws IOException
Unregisters input and output sockets.- Specified by:
close
in interfaceAutoCloseable
- Specified by:
close
in interfaceCloseable
- Throws:
IOException
-
-