Package zmq.socket.scattergather
Class Gather
java.lang.Object
zmq.ZObject
zmq.Own
zmq.SocketBase
zmq.socket.scattergather.Gather
- All Implemented Interfaces:
Pipe.IPipeEvents
,IPollEvents
-
Field Summary
FieldsFields inherited from class zmq.SocketBase
connectRid
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected Blob
protected void
xattachPipe
(Pipe pipe, boolean subscribe2all, boolean isLocallyInitiated) protected boolean
xhasIn()
protected void
xpipeTerminated
(Pipe pipe) protected void
xreadActivated
(Pipe pipe) protected Msg
xrecv()
Methods inherited from class zmq.SocketBase
bind, cancel, close, connect, connectPeer, destroy, 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, xdisconnectPeer, xhasOut, xhiccuped, xjoin, xleave, xsend, xsetsockopt, xwriteActivated
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
-
-
Constructor Details
-
Gather
-
-
Method Details
-
xattachPipe
- Specified by:
xattachPipe
in classSocketBase
-
xrecv
- Overrides:
xrecv
in classSocketBase
-
xhasIn
protected boolean xhasIn()- Overrides:
xhasIn
in classSocketBase
-
getCredential
- Overrides:
getCredential
in classSocketBase
-
xreadActivated
- Overrides:
xreadActivated
in classSocketBase
-
xpipeTerminated
- Specified by:
xpipeTerminated
in classSocketBase
-