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 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()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
flow(ZProxy.Plug splug, ZMQ.Socket source, ZMQ.Socket capture, ZProxy.Plug dplug, ZMQ.Socket destination)
Transfers a message from one source to one destination, with an optional capture.
-
-
-
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 interfaceZProxy.Pump
- Parameters:
splug
- the plug of the source socketsource
- 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 socketdestination
- the socket where to send the message to.- Returns:
- false in case of error or interruption, true if successfully transferred the message
-
-