org.zeromq
Class ZMQQueue

java.lang.Object
  org.zeromq.ZMQQueue

All Implemented Interfaces:

Closeable, Runnable

public class ZMQQueue
extends Object
implements Runnable, Closeable

ZeroMQ Queue Device implementation.

Author:

Alois Belaska

Constructor Summary

ZMQQueue(ZMQ.Context context, ZMQ.Socket inSocket, ZMQ.Socket outSocket)
Class constructor.

Method Summary

void	close() Unregisters input and output sockets.
void	run() Queuing of requests and replies.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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 socket

outSocket - output socket

Method Detail

run

public void run()

Queuing of requests and replies.

Specified by:

run in interface Runnable

close

public void close()
           throws IOException

Unregisters input and output sockets.

Specified by:

close in interface Closeable

Throws:

IOException