Package zmq.socket.reqrep
Class Router
java.lang.Object
zmq.ZObject
zmq.Own
zmq.SocketBase
zmq.socket.reqrep.Router
- All Implemented Interfaces:
Pipe.IPipeEvents
,IPollEvents
- Direct Known Subclasses:
Rep
-
Nested Class Summary
Nested Classes -
Field Summary
FieldsModifier and TypeFieldDescriptionprivate Pipe
private final FQ
private boolean
private boolean
private boolean
private boolean
private boolean
private int
private final Map
<Blob, Router.Outpipe> private boolean
private Msg
private Msg
private boolean
private boolean
Fields inherited from class zmq.SocketBase
connectRid
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected void
destroy()
protected Blob
private boolean
identifyPeer
(Pipe pipe, boolean isLocallyInitiated) protected boolean
rollback()
void
xattachPipe
(Pipe pipe, boolean subscribe2all, boolean isLocallyInitiated) protected boolean
xhasIn()
protected boolean
xhasOut()
void
xpipeTerminated
(Pipe pipe) void
xreadActivated
(Pipe pipe) protected Msg
xrecv()
protected boolean
boolean
xsetsockopt
(int option, Object optval) void
xwriteActivated
(Pipe pipe) Methods inherited from class zmq.SocketBase
bind, close, connect, errno, eventAccepted, eventAcceptFailed, eventBindFailed, eventClosed, eventCloseFailed, eventConnectDelayed, eventConnected, eventConnectRetried, eventDisconnected, eventHandshaken, eventListening, getFD, getSocketOpt, getSocketOptx, hiccuped, inEvent, monitor, monitorEvent, pipeTerminated, processBind, processDestroy, processStop, processTerm, readActivated, recv, send, setSocketOpt, termEndpoint, toString, typeString, writeActivated, xhiccuped
Methods inherited from class zmq.Own
incSeqnum, isTerminating, launchChild, processOwn, processSeqnum, processTermAck, processTermReq, termChild, terminate
Methods inherited from class zmq.ZObject
chooseIoThread, connectPending, destroySocket, findEndpoint, getCtx, getTid, pendConnection, processActivateRead, processActivateWrite, processAttach, processHiccup, processPipeTerm, processPipeTermAck, processPlug, processReap, processReaped, registerEndpoint, sendActivateRead, sendActivateWrite, sendAttach, sendAttach, sendBind, sendBind, sendDone, sendHiccup, sendInprocConnected, sendOwn, sendPipeTerm, sendPipeTermAck, sendPlug, sendPlug, sendReap, sendReaped, sendStop, sendTerm, sendTermAck, sendTermReq, setTid, unregisterEndpoint, unregisterEndpoints
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
Methods inherited from interface zmq.poll.IPollEvents
acceptEvent, connectEvent, outEvent, timerEvent
-
Field Details
-
fq
-
prefetched
private boolean prefetched -
identitySent
private boolean identitySent -
prefetchedId
-
prefetchedMsg
-
moreIn
private boolean moreIn -
anonymousPipes
-
outpipes
-
currentOut
-
moreOut
private boolean moreOut -
nextRid
private int nextRid -
mandatory
private boolean mandatory -
rawSocket
private boolean rawSocket -
probeRouter
private boolean probeRouter -
handover
private boolean handover
-
-
Constructor Details
-
Router
-
-
Method Details
-
destroy
protected void destroy()- Overrides:
destroy
in classSocketBase
-
xattachPipe
- Specified by:
xattachPipe
in classSocketBase
-
xsetsockopt
- Overrides:
xsetsockopt
in classSocketBase
-
xpipeTerminated
- Specified by:
xpipeTerminated
in classSocketBase
-
xreadActivated
- Overrides:
xreadActivated
in classSocketBase
-
xwriteActivated
- Overrides:
xwriteActivated
in classSocketBase
-
xsend
- Overrides:
xsend
in classSocketBase
-
xrecv
- Overrides:
xrecv
in classSocketBase
-
rollback
protected boolean rollback() -
xhasIn
protected boolean xhasIn()- Overrides:
xhasIn
in classSocketBase
-
xhasOut
protected boolean xhasOut()- Overrides:
xhasOut
in classSocketBase
-
getCredential
- Overrides:
getCredential
in classSocketBase
-
identifyPeer
-