public static class ZProxy.ZPump extends java.lang.Object implements ZProxy.Pump
Modifier and Type | Class and Description |
---|---|
private static class |
ZProxy.ZPump.Identity |
static interface |
ZProxy.ZPump.Transformer |
Modifier and Type | Field and Description |
---|---|
private static ZProxy.ZPump.Identity |
IDENTITY |
private ZProxy.ZPump.Transformer |
transformer |
Constructor and Description |
---|
ZPump() |
ZPump(ZProxy.ZPump.Transformer transformer) |
Modifier and Type | Method and 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.
|
private static final ZProxy.ZPump.Identity IDENTITY
private final ZProxy.ZPump.Transformer transformer
public ZPump()
public ZPump(ZProxy.ZPump.Transformer transformer)
public boolean flow(ZProxy.Plug splug, ZMQ.Socket source, ZMQ.Socket capture, ZProxy.Plug dplug, ZMQ.Socket destination)
ZProxy.Pump
flow
in interface ZProxy.Pump
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.