Package zmq.socket.clientserver
Class Server
java.lang.Object
zmq.ZObject
zmq.Own
zmq.SocketBase
zmq.socket.clientserver.Server
- All Implemented Interfaces:
Pipe.IPipeEvents
,IPollEvents
- Direct Known Subclasses:
Peer
-
Nested Class Summary
Nested Classes -
Field Summary
FieldsModifier and TypeFieldDescriptionprivate final FQ
private int
private final Map
<Integer, Server.Outpipe> Fields inherited from class zmq.SocketBase
connectRid
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected void
destroy()
protected Blob
void
xattachPipe
(Pipe pipe, boolean subscribe2all, boolean isLocallyInitiated) protected boolean
xdisconnectPeer
(int routingId) protected boolean
xhasIn()
protected boolean
xhasOut()
void
xpipeTerminated
(Pipe pipe) void
xreadActivated
(Pipe pipe) protected Msg
xrecv()
protected boolean
void
xwriteActivated
(Pipe pipe) Methods inherited from class zmq.SocketBase
bind, cancel, close, connect, connectPeer, disconnectPeer, errno, eventAccepted, eventAcceptFailed, eventBindFailed, eventClosed, eventCloseFailed, eventConnectDelayed, eventConnected, eventConnectRetried, eventDisconnected, eventHandshakeFailedAuth, eventHandshakeFailedNoDetail, eventHandshakeFailedProtocol, eventHandshaken, eventHandshakeSucceeded, eventListening, getFD, getSocketOpt, getSocketOptx, hiccuped, inEvent, join, leave, monitor, monitorEvent, pipeTerminated, poll, processBind, processDestroy, processStop, processTerm, readActivated, recv, recv, send, send, setSocketOpt, termEndpoint, toString, typeString, writeActivated, xhiccuped, xjoin, xleave, xsetsockopt
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, processCancel, processHiccup, processPipeTerm, processPipeTermAck, processPlug, processReap, processReapAck, processReaped, registerEndpoint, sendActivateRead, sendActivateWrite, sendAttach, sendAttach, sendBind, sendBind, sendCancel, sendDone, sendHiccup, sendInprocConnected, sendOwn, sendPipeTerm, sendPipeTermAck, sendPlug, sendPlug, sendReap, sendReapAck, 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
-
outpipes
-
nextRid
private int nextRid
-
-
Constructor Details
-
Server
-
-
Method Details
-
destroy
protected void destroy()- Overrides:
destroy
in classSocketBase
-
xattachPipe
- Specified by:
xattachPipe
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
-
xhasIn
protected boolean xhasIn()- Overrides:
xhasIn
in classSocketBase
-
xhasOut
protected boolean xhasOut()- Overrides:
xhasOut
in classSocketBase
-
getCredential
- Overrides:
getCredential
in classSocketBase
-
xdisconnectPeer
protected boolean xdisconnectPeer(int routingId) - Overrides:
xdisconnectPeer
in classSocketBase
-