Package org.zeromq

Class ZMQQueue

java.lang.Object
org.zeromq.ZMQQueue
All Implemented Interfaces:
Closeable, AutoCloseable, Runnable

public class ZMQQueue extends Object implements Runnable, Closeable
ZeroMQ Queue Device implementation.
  • Constructor Details

    • 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 Details