public class Router extends SocketBase
Modifier and Type | Class and Description |
---|---|
static class |
Router.RouterSession |
Modifier and Type | Field and Description |
---|---|
protected Options |
options |
errno
Modifier and Type | Method and Description |
---|---|
protected boolean |
isTerminating() |
protected void |
launchChild(zmq.Own object) |
protected void |
processOwn(zmq.Own object) |
protected void |
processSeqnum() |
protected void |
processTermAck() |
protected void |
processTermReq(zmq.Own object) |
void |
registerTermAcks(int count) |
protected void |
rollback() |
protected void |
termChild(zmq.Own object) |
protected void |
terminate() |
void |
unregisterTermAck() |
void |
xattachPipe(zmq.Pipe pipe,
boolean icanhasall) |
protected boolean |
xhasIn() |
protected boolean |
xhasOut() |
void |
xpipeTerminated(zmq.Pipe pipe) |
void |
xreadActivated(zmq.Pipe pipe) |
protected Msg |
xrecv() |
protected boolean |
xsend(Msg msg) |
boolean |
xsetsockopt(int option,
Object optval) |
void |
xwriteActivated(zmq.Pipe pipe) |
acceptEvent, bind, checkTag, close, connect, connectEvent, create, destroy, errno, eventAccepted, eventAcceptFailed, eventBindFailed, eventClosed, eventCloseFailed, eventConnectDelayed, eventConnected, eventConnectRetried, eventDisconnected, eventListening, getFD, getMailbox, getSocketOpt, getsockoptx, hiccuped, inEvent, monitor, monitorEvent, outEvent, pipeTerminated, processBind, processDestroy, processStop, processTerm, readActivated, recv, send, setSocketOpt, startReaping, stop, stopMonitor, termEndpoint, timerEvent, toString, typeString, writeActivated, xhiccuped
chooseIoThread, destroySocket, findEndpoint, getCtx, getTid, processActivateRead, processActivateWrite, processAttach, processCommand, processHiccup, processPipeTerm, processPipeTermAck, processPlug, processReap, processReaped, registerEndpoint, sendActivateRead, sendActivateWrite, sendAttach, sendAttach, sendBind, sendBind, sendDone, sendHiccup, sendOwn, sendPipeTerm, sendPipeTermAck, sendPlug, sendPlug, sendReap, sendReaped, sendStop, sendTerm, sendTermAck, sendTermReq, unregisterEndpoints
protected final Options options
public Router(Ctx parent, int tid, int sid)
public void xattachPipe(zmq.Pipe pipe, boolean icanhasall)
xattachPipe
in class SocketBase
public boolean xsetsockopt(int option, Object optval)
xsetsockopt
in class SocketBase
public void xpipeTerminated(zmq.Pipe pipe)
xpipeTerminated
in class SocketBase
public void xreadActivated(zmq.Pipe pipe)
xreadActivated
in class SocketBase
public void xwriteActivated(zmq.Pipe pipe)
xwriteActivated
in class SocketBase
protected boolean xsend(Msg msg)
xsend
in class SocketBase
protected Msg xrecv()
xrecv
in class SocketBase
protected void rollback()
protected boolean xhasIn()
xhasIn
in class SocketBase
protected boolean xhasOut()
xhasOut
in class SocketBase
protected void processSeqnum()
processSeqnum
in class ZObject
protected void launchChild(zmq.Own object)
protected void termChild(zmq.Own object)
protected void processTermReq(zmq.Own object)
processTermReq
in class ZObject
protected void processOwn(zmq.Own object)
processOwn
in class ZObject
protected void terminate()
protected boolean isTerminating()
public void registerTermAcks(int count)
public void unregisterTermAck()
protected void processTermAck()
processTermAck
in class ZObject
Copyright © 2023. All rights reserved.