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

Method Summary

Modifier and Type	Method	Description
boolean	checkHwm()
boolean	checkRead()
boolean	checkWrite()
void	flush()
Blob	getCredential()
Blob	getIdentity()
int	getRoutingId()
void	hiccup()
static Pipe[]	pair(ZObject[] parents, int[] hwms, boolean[] conflates)
protected void	processActivateRead()
protected void	processActivateWrite(long msgsRead)
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()
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

Method Details

pair

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

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)

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