Package org.zeromq
Class ZMQQueue
java.lang.Object
org.zeromq.ZMQQueue
- All Implemented Interfaces:
Closeable
,AutoCloseable
,Runnable
ZeroMQ Queue Device implementation.
-
Constructor Summary
ConstructorsConstructorDescriptionZMQQueue
(ZMQ.Context context, ZMQ.Socket inSocket, ZMQ.Socket outSocket) Class constructor. -
Method Summary
-
Constructor Details
-
ZMQQueue
Class constructor.- Parameters:
context
- a 0MQ context previously created.inSocket
- input socketoutSocket
- output socket
-
-
Method Details
-
run
public void run()Queuing of requests and replies. -
close
Unregisters input and output sockets.- Specified by:
close
in interfaceAutoCloseable
- Specified by:
close
in interfaceCloseable
- Throws:
IOException
-