Package org.zeromq

Class ZProxy.ZPump

java.lang.Object
org.zeromq.ZProxy.ZPump
All Implemented Interfaces:
ZProxy.Pump
Enclosing class:
ZProxy

public static class ZProxy.ZPump extends Object implements ZProxy.Pump
A pump that reads a message as a whole before transmitting it. It offers a way to transform messages for capture and destination.
  • Field Details

  • Constructor Details

  • Method Details

    • flow

      public boolean flow(ZProxy.Plug splug, ZMQ.Socket source, ZMQ.Socket capture, ZProxy.Plug dplug, ZMQ.Socket destination)
      Description copied from interface: ZProxy.Pump
      Transfers a message from one source to one destination, with an optional capture.
      Specified by:
      flow in interface ZProxy.Pump
      Parameters:
      splug - the plug of the source socket
      source - the socket where to receive the message from.
      capture - the optional sockets where to send the message to. Possibly null.
      dplug - the plug of the destination socket
      destination - the socket where to send the message to.
      Returns:
      false in case of error or interruption, true if successfully transferred the message