org.zeromq

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 java.lang.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 and Description
private	ZmqPump()

Method Summary

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.

Methods inherited from class java.lang.Object

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

Constructor Detail

ZmqPump

private ZmqPump()

Method Detail

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