Package org.zeromq
Class ZProxy.ZPump
java.lang.Object
org.zeromq.ZProxy.ZPump
- All Implemented Interfaces:
ZProxy.Pump
- Enclosing class:
- ZProxy
A pump that reads a message as a whole before transmitting it.
It offers a way to transform messages for capture and destination.
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionprivate static class
static interface
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate static final ZProxy.ZPump.Identity
private final ZProxy.ZPump.Transformer
-
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.
-
Field Details
-
IDENTITY
-
transformer
-
-
Constructor Details
-
ZPump
public ZPump() -
ZPump
-
-
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
-