Class Pipe

java.lang.Object

zmq.ZObject

zmq.pipe.Pipe

public class Pipe
extends ZObject

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	Pipe.IPipeEvents
(package private) static enum	Pipe.State

Field Summary

Fields

Modifier and Type	Field	Description
private final boolean	conflate
private Blob	credential
private boolean	delay
private Msg	disconnectMsg
private int	hwm
private Blob	identity
private boolean	inActive
private YPipeBase<Msg>	inpipe
private int	lwm
private long	msgsRead
private long	msgsWritten
private boolean	outActive
private YPipeBase<Msg>	outpipe
private final ZObject	parent
private Pipe	peer
private long	peersMsgsRead
private int	routingId
private Pipe.IPipeEvents	sink
private Pipe.State	state

Constructor Summary

Constructors

Modifier	Constructor	Description
private	Pipe(ZObject parent, YPipeBase<Msg> inpipe, YPipeBase<Msg> outpipe, int inhwm, int outhwm, boolean conflate)

Method Summary

Modifier and Type	Method	Description
boolean	checkHwm()
boolean	checkRead()
boolean	checkWrite()
private static int	computeLwm(int hwm)
void	flush()
Blob	getCredential()
Blob	getIdentity()
int	getRoutingId()
void	hiccup()
private static boolean	isDelimiter(Msg msg)
static Pipe[]	pair(ZObject[] parents, int[] hwms, boolean[] conflates)
protected void	processActivateRead()
protected void	processActivateWrite(long msgsRead)
private void	processDelimiter()
protected void	processHiccup(YPipeBase<Msg> pipe)
protected void	processPipeTerm()
protected void	processPipeTermAck()
Msg	read()
void	rollback()
void	sendDisconnectMsg()
void	sendHiccupMsg(Msg hiccupMsg)
void	setDisconnectMsg(Msg msg)
void	setEventSink(Pipe.IPipeEvents sink)
void	setHwms(int inhwm, int outhwm)
void	setIdentity(Blob identity)
void	setNoDelay()
private void	setPeer(Pipe peer)
void	setRoutingId(int routingId)
void	terminate(boolean delay)
String	toString()
boolean	write(Msg msg)

Methods inherited from class ZObject

chooseIoThread, connectPending, destroySocket, findEndpoint, getCtx, getTid, pendConnection, processAttach, processBind, processCancel, processOwn, processPlug, processReap, processReapAck, processReaped, processSeqnum, processStop, processTerm, processTermAck, processTermReq, registerEndpoint, sendActivateRead, sendActivateWrite, sendAttach, sendAttach, sendBind, sendBind, sendCancel, sendDone, sendHiccup, sendInprocConnected, sendOwn, sendPipeTerm, sendPipeTermAck, sendPlug, sendPlug, sendReap, sendReapAck, sendReaped, sendStop, sendTerm, sendTermAck, sendTermReq, setTid, unregisterEndpoint, unregisterEndpoints

Methods inherited from class Object

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

Field Details

inpipe

private YPipeBase<Msg> inpipe

outpipe

private YPipeBase<Msg> outpipe

inActive

private boolean inActive

outActive

private boolean outActive

hwm

private int hwm

lwm

private int lwm

msgsRead

private long msgsRead

msgsWritten

private long msgsWritten

peersMsgsRead

private long peersMsgsRead

peer

private Pipe peer

sink

private Pipe.IPipeEvents sink

state

private Pipe.State state

delay

private boolean delay

identity

private Blob identity

routingId

private int routingId

credential

private Blob credential

conflate

private final boolean conflate

disconnectMsg

private Msg disconnectMsg

parent

private final ZObject parent

Constructor Details

Pipe

private Pipe(ZObject parent,
 YPipeBase<Msg> inpipe,
 YPipeBase<Msg> outpipe,
 int inhwm,
 int outhwm,
 boolean conflate)

Method Details

pair

public static Pipe[] pair(ZObject[] parents,
 int[] hwms,
 boolean[] conflates)

setPeer

private void setPeer(Pipe peer)

setEventSink

public void setEventSink(Pipe.IPipeEvents sink)

setIdentity

public void setIdentity(Blob identity)

getIdentity

public Blob getIdentity()

setRoutingId

public void setRoutingId(int routingId)

getRoutingId

public int getRoutingId()

getCredential

public Blob getCredential()

checkRead

public boolean checkRead()

read

public Msg read()

checkWrite

public boolean checkWrite()

write

public boolean write(Msg msg)

rollback

public void rollback()

flush

public void flush()

processActivateRead

protected void processActivateRead()

Overrides:

processActivateRead in class ZObject

processActivateWrite

protected void processActivateWrite(long msgsRead)

Overrides:

processActivateWrite in class ZObject

processHiccup

protected void processHiccup(YPipeBase<Msg> pipe)

Overrides:

processHiccup in class ZObject

processPipeTerm

protected void processPipeTerm()

Overrides:

processPipeTerm in class ZObject

processPipeTermAck

protected void processPipeTermAck()

Overrides:

processPipeTermAck in class ZObject

setNoDelay

public void setNoDelay()

terminate

public void terminate(boolean delay)

isDelimiter

private static boolean isDelimiter(Msg msg)

computeLwm

private static int computeLwm(int hwm)

processDelimiter

private void processDelimiter()

hiccup

public void hiccup()

setHwms

public void setHwms(int inhwm,
 int outhwm)

checkHwm

public boolean checkHwm()

setDisconnectMsg

public void setDisconnectMsg(Msg msg)

sendDisconnectMsg

public void sendDisconnectMsg()

sendHiccupMsg

public void sendHiccupMsg(Msg hiccupMsg)

toString

public String toString()

Overrides:

toString in class Object