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

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

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