Package zmq.pipe
Class Pipe
java.lang.Object
zmq.ZObject
zmq.pipe.Pipe
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic interface
(package private) static enum
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate final boolean
private Blob
private boolean
private Msg
private int
private Blob
private boolean
private int
private long
private long
private boolean
private final ZObject
private Pipe
private long
private int
private Pipe.IPipeEvents
private Pipe.State
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionboolean
checkHwm()
boolean
boolean
private static int
computeLwm
(int hwm) void
flush()
int
void
hiccup()
private static boolean
isDelimiter
(Msg msg) static Pipe[]
protected void
protected void
processActivateWrite
(long msgsRead) private void
protected void
processHiccup
(YPipeBase<Msg> pipe) protected void
protected void
read()
void
rollback()
void
void
sendHiccupMsg
(Msg hiccupMsg) void
setDisconnectMsg
(Msg msg) void
setEventSink
(Pipe.IPipeEvents sink) void
setHwms
(int inhwm, int outhwm) void
setIdentity
(Blob identity) void
private void
void
setRoutingId
(int routingId) void
terminate
(boolean delay) toString()
boolean
Methods inherited from class zmq.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
-
Field Details
-
inpipe
-
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
-
sink
-
state
-
delay
private boolean delay -
identity
-
routingId
private int routingId -
credential
-
conflate
private final boolean conflate -
disconnectMsg
-
parent
-
-
Constructor Details
-
Pipe
-
-
Method Details
-
pair
-
setPeer
-
setEventSink
-
setIdentity
-
getIdentity
-
setRoutingId
public void setRoutingId(int routingId) -
getRoutingId
public int getRoutingId() -
getCredential
-
checkRead
public boolean checkRead() -
read
-
checkWrite
public boolean checkWrite() -
write
-
rollback
public void rollback() -
flush
public void flush() -
processActivateRead
protected void processActivateRead()- Overrides:
processActivateRead
in classZObject
-
processActivateWrite
protected void processActivateWrite(long msgsRead) - Overrides:
processActivateWrite
in classZObject
-
processHiccup
- Overrides:
processHiccup
in classZObject
-
processPipeTerm
protected void processPipeTerm()- Overrides:
processPipeTerm
in classZObject
-
processPipeTermAck
protected void processPipeTermAck()- Overrides:
processPipeTermAck
in classZObject
-
setNoDelay
public void setNoDelay() -
terminate
public void terminate(boolean delay) -
isDelimiter
-
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
-
sendDisconnectMsg
public void sendDisconnectMsg() -
sendHiccupMsg
-
toString
-