Package org.zeromq
Class ZProxy.ZmqPump
java.lang.Object
org.zeromq.ZProxy.ZmqPump
- All Implemented Interfaces:
ZProxy.Pump
- Enclosing class:
ZProxy
A specialized transport for better transmission purposes
that will send each packets individually instead of the whole message.
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionboolean
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.
-
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 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
-