Package org.zeromq

Class ZProxy.ZmqPump

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

private static final class ZProxy.ZmqPump extends Object implements ZProxy.Pump
A specialized transport for better transmission purposes that will send each packets individually instead of the whole message.
  • Constructor Details

    • ZmqPump

      private ZmqPump()
  • 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