Package org.zeromq

Class ZProxy.ZmqPump

  • All Implemented Interfaces:
    ZProxy.Pump
    Enclosing class:
    ZProxy

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

      Constructors 
      Modifier Constructor Description
      private ZmqPump()  
    • Constructor Detail

      • ZmqPump

        private ZmqPump()
    • Method Detail

      • 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