Class ZProxy.ZPump

java.lang.Object

org.zeromq.ZProxy.ZPump

All Implemented Interfaces:

ZProxy.Pump

Enclosing class:

ZProxy

public static class ZProxy.ZPump
extends Object
implements ZProxy.Pump

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 Classes

Modifier and Type	Class	Description
private static class	ZProxy.ZPump.Identity
static interface	ZProxy.ZPump.Transformer

Field Summary

Fields

Modifier and Type	Field	Description
private static final ZProxy.ZPump.Identity	IDENTITY
private final ZProxy.ZPump.Transformer	transformer

Constructor Summary

Constructors

Constructor	Description
ZPump()
ZPump(ZProxy.ZPump.Transformer transformer)

Method Summary

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.

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

IDENTITY

private static final ZProxy.ZPump.Identity IDENTITY

transformer

private final ZProxy.ZPump.Transformer transformer

Constructor Details

ZPump

public ZPump()

ZPump

public ZPump(ZProxy.ZPump.Transformer transformer)

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 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