Package zmq.pipe
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 class
Pipe.State
-
Field Summary
Fields Modifier and Type Field Description private boolean
conflate
private Blob
credential
private boolean
delay
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 ZObject
parent
private Pipe
peer
private long
peersMsgsRead
private Pipe.IPipeEvents
sink
private Pipe.State
state
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
checkHwm()
boolean
checkRead()
boolean
checkWrite()
private static int
computeLwm(int hwm)
void
flush()
Blob
getCredential()
Blob
getIdentity()
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
setEventSink(Pipe.IPipeEvents sink)
void
setHwms(int inhwm, int outhwm)
void
setIdentity(Blob identity)
void
setNoDelay()
private void
setPeer(Pipe peer)
void
terminate(boolean delay)
java.lang.String
toString()
boolean
write(Msg msg)
-
Methods inherited from class zmq.ZObject
chooseIoThread, connectPending, destroySocket, findEndpoint, getCtx, getTid, pendConnection, processAttach, processBind, processOwn, processPlug, processReap, processReaped, processSeqnum, processStop, processTerm, processTermAck, processTermReq, registerEndpoint, sendActivateRead, sendActivateWrite, sendAttach, sendAttach, sendBind, sendBind, sendDone, sendHiccup, sendInprocConnected, sendOwn, sendPipeTerm, sendPipeTermAck, sendPlug, sendPlug, sendReap, sendReaped, sendStop, sendTerm, sendTermAck, sendTermReq, setTid, unregisterEndpoint, unregisterEndpoints
-
-
-
-
Field Detail
-
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
-
credential
private Blob credential
-
conflate
private final boolean conflate
-
parent
private final ZObject parent
-
-
Method Detail
-
setPeer
private void setPeer(Pipe peer)
-
setEventSink
public void setEventSink(Pipe.IPipeEvents sink)
-
setIdentity
public void setIdentity(Blob identity)
-
getIdentity
public Blob getIdentity()
-
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 classZObject
-
processActivateWrite
protected void processActivateWrite(long msgsRead)
- Overrides:
processActivateWrite
in classZObject
-
processHiccup
protected void processHiccup(YPipeBase<Msg> pipe)
- 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
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()
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-