Package zmq
Class ZObject
java.lang.Object
zmq.ZObject
-
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected final IOThread
chooseIoThread
(long affinity) protected final void
connectPending
(String addr, SocketBase bindSocket) protected final void
destroySocket
(SocketBase socket) protected final Ctx.Endpoint
findEndpoint
(String addr) protected final Ctx
getCtx()
final int
getTid()
protected final void
pendConnection
(String addr, Ctx.Endpoint endpoint, Pipe[] pipes) protected void
protected void
processActivateWrite
(long msgsRead) protected void
processAttach
(IEngine engine) protected void
processBind
(Pipe pipe) protected void
(package private) final void
processCommand
(Command cmd) protected void
processHiccup
(YPipeBase<Msg> hiccupPipe) protected void
processOwn
(Own object) protected void
protected void
protected void
protected void
processReap
(SocketBase socket) protected void
protected void
protected void
protected void
protected void
processTerm
(int linger) protected void
protected void
processTermReq
(Own object) protected final boolean
registerEndpoint
(String addr, Ctx.Endpoint endpoint) protected final void
sendActivateRead
(Pipe destination) protected final void
sendActivateWrite
(Pipe destination, long msgsRead) protected final void
sendAttach
(SessionBase destination, IEngine engine) protected final void
sendAttach
(SessionBase destination, IEngine engine, boolean incSeqnum) protected final void
protected final void
protected final void
private void
sendCommand
(Command cmd) protected final void
sendDone()
protected final void
sendHiccup
(Pipe destination, YPipeBase<Msg> pipe) protected final void
sendInprocConnected
(SocketBase socket) protected final void
protected final void
sendPipeTerm
(Pipe destination) protected final void
sendPipeTermAck
(Pipe destination) protected final void
protected final void
protected final void
sendReap
(SocketBase socket) protected final void
protected final void
protected final void
sendStop()
protected final void
protected final void
sendTermAck
(Own destination) protected final void
sendTermReq
(Own destination, Own object) protected final void
setTid
(int tid) protected final boolean
unregisterEndpoint
(String addr, SocketBase socket) protected final void
unregisterEndpoints
(SocketBase socket)
-
Field Details
-
ctx
-
tid
private int tid
-
-
Constructor Details
-
ZObject
-
ZObject
-
-
Method Details
-
getTid
public final int getTid() -
setTid
protected final void setTid(int tid) -
getCtx
-
processCommand
-
registerEndpoint
-
unregisterEndpoint
-
unregisterEndpoints
-
findEndpoint
-
pendConnection
-
connectPending
-
destroySocket
-
chooseIoThread
-
sendStop
protected final void sendStop() -
sendPlug
-
sendPlug
-
sendOwn
-
sendAttach
-
sendAttach
-
sendBind
-
sendBind
-
sendActivateRead
-
sendActivateWrite
-
sendHiccup
-
sendPipeTerm
-
sendPipeTermAck
-
sendTermReq
-
sendTerm
-
sendTermAck
-
sendReap
-
sendReapAck
protected final void sendReapAck() -
sendReaped
protected final void sendReaped() -
sendInprocConnected
-
sendDone
protected final void sendDone() -
sendCancel
protected final void sendCancel() -
processStop
protected void processStop() -
processPlug
protected void processPlug() -
processOwn
-
processAttach
-
processBind
-
processActivateRead
protected void processActivateRead() -
processActivateWrite
protected void processActivateWrite(long msgsRead) -
processHiccup
-
processPipeTerm
protected void processPipeTerm() -
processPipeTermAck
protected void processPipeTermAck() -
processTermReq
-
processTerm
protected void processTerm(int linger) -
processTermAck
protected void processTermAck() -
processReap
-
processReapAck
protected void processReapAck() -
processReaped
protected void processReaped() -
processSeqnum
protected void processSeqnum() -
processCancel
protected void processCancel() -
sendCommand
-