public class Rep extends Router
Modifier and Type | Class and Description |
---|---|
static class |
Rep.RepSession |
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 |
termChild(zmq.Own object) |
protected void |
terminate() |
void |
unregisterTermAck() |
protected boolean |
xhasIn() |
protected boolean |
xhasOut() |
protected Msg |
xrecv() |
protected boolean |
xsend(Msg msg) |
rollback, xattachPipe, xpipeTerminated, xreadActivated, xsetsockopt, xwriteActivated
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 Rep(Ctx parent, int tid, int sid)
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 © 2022. All rights reserved.