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
public class Router extends SocketBase
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description (package private) class
Router.Outpipe
-
Field Summary
Fields Modifier and Type Field Description private java.util.Set<Pipe>
anonymousPipes
private Pipe
currentOut
private FQ
fq
private boolean
handover
private boolean
identitySent
private boolean
mandatory
private boolean
moreIn
private boolean
moreOut
private int
nextRid
private java.util.Map<Blob,Router.Outpipe>
outpipes
private boolean
prefetched
private Msg
prefetchedId
private Msg
prefetchedMsg
private boolean
probeRouter
private boolean
rawSocket
-
Fields inherited from class zmq.SocketBase
connectRid
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
destroy()
protected Blob
getCredential()
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
xsend(Msg msg)
boolean
xsetsockopt(int option, java.lang.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 Detail
-
fq
private final FQ fq
-
prefetched
private boolean prefetched
-
identitySent
private boolean identitySent
-
prefetchedId
private Msg prefetchedId
-
prefetchedMsg
private Msg prefetchedMsg
-
moreIn
private boolean moreIn
-
anonymousPipes
private final java.util.Set<Pipe> anonymousPipes
-
outpipes
private final java.util.Map<Blob,Router.Outpipe> outpipes
-
currentOut
private Pipe 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 Detail
-
Router
public Router(Ctx parent, int tid, int sid)
-
-
Method Detail
-
destroy
protected void destroy()
- Overrides:
destroy
in classSocketBase
-
xattachPipe
public void xattachPipe(Pipe pipe, boolean subscribe2all, boolean isLocallyInitiated)
- Specified by:
xattachPipe
in classSocketBase
-
xsetsockopt
public boolean xsetsockopt(int option, java.lang.Object optval)
- Overrides:
xsetsockopt
in classSocketBase
-
xpipeTerminated
public void xpipeTerminated(Pipe pipe)
- Specified by:
xpipeTerminated
in classSocketBase
-
xreadActivated
public void xreadActivated(Pipe pipe)
- Overrides:
xreadActivated
in classSocketBase
-
xwriteActivated
public void xwriteActivated(Pipe pipe)
- Overrides:
xwriteActivated
in classSocketBase
-
xsend
protected boolean xsend(Msg msg)
- Overrides:
xsend
in classSocketBase
-
xrecv
protected Msg 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
protected Blob getCredential()
- Overrides:
getCredential
in classSocketBase
-
identifyPeer
private boolean identifyPeer(Pipe pipe, boolean isLocallyInitiated)
-
-