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
public class Gather extends SocketBase
-
-
Field Summary
Fields Modifier and Type Field Description private FQ
fq
-
Fields inherited from class zmq.SocketBase
connectRid
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected Blob
getCredential()
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 Detail
-
fq
private final FQ fq
-
-
Constructor Detail
-
Gather
public Gather(Ctx parent, int tid, int sid)
-
-
Method Detail
-
xattachPipe
protected void xattachPipe(Pipe pipe, boolean subscribe2all, boolean isLocallyInitiated)
- Specified by:
xattachPipe
in classSocketBase
-
xrecv
protected Msg xrecv()
- Overrides:
xrecv
in classSocketBase
-
xhasIn
protected boolean xhasIn()
- Overrides:
xhasIn
in classSocketBase
-
getCredential
protected Blob getCredential()
- Overrides:
getCredential
in classSocketBase
-
xreadActivated
protected void xreadActivated(Pipe pipe)
- Overrides:
xreadActivated
in classSocketBase
-
xpipeTerminated
protected void xpipeTerminated(Pipe pipe)
- Specified by:
xpipeTerminated
in classSocketBase
-
-