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
public class Server extends SocketBase
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description (package private) class
Server.Outpipe
-
Field Summary
Fields Modifier and Type Field Description private FQ
fq
private int
nextRid
private java.util.Map<java.lang.Integer,Server.Outpipe>
outpipes
-
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()
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
xsend(Msg msg)
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 Detail
-
fq
private final FQ fq
-
outpipes
private final java.util.Map<java.lang.Integer,Server.Outpipe> outpipes
-
nextRid
private int nextRid
-
-
Constructor Detail
-
Server
public Server(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
-
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
-
xhasIn
protected boolean xhasIn()
- Overrides:
xhasIn
in classSocketBase
-
xhasOut
protected boolean xhasOut()
- Overrides:
xhasOut
in classSocketBase
-
getCredential
protected Blob getCredential()
- Overrides:
getCredential
in classSocketBase
-
xdisconnectPeer
protected boolean xdisconnectPeer(int routingId)
- Overrides:
xdisconnectPeer
in classSocketBase
-
-