Package zmq.socket.pubsub
Class XPub
java.lang.Object
zmq.ZObject
zmq.Own
zmq.SocketBase
zmq.socket.pubsub.XPub
- All Implemented Interfaces:
Pipe.IPipeEvents
,IPollEvents
- Direct Known Subclasses:
Pub
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionprivate static final class
private static final class
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate final Dist
private Pipe
private boolean
private boolean
private final Mtrie
private static final Mtrie.IMtrieHandler
private boolean
private static final Mtrie.IMtrieHandler
private final Mtrie
private boolean
private boolean
Fields inherited from class zmq.SocketBase
connectRid
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprivate void
markAsMatching
(Pipe pipe) private void
sendUnsubscription
(byte[] data, int size) protected void
xattachPipe
(Pipe pipe, boolean subscribeToAll, boolean isLocallyInitiated) protected boolean
xhasIn()
protected boolean
xhasOut()
protected void
xpipeTerminated
(Pipe pipe) protected void
xreadActivated
(Pipe pipe) protected Msg
xrecv()
protected boolean
boolean
xsetsockopt
(int option, Object optval) protected void
xwriteActivated
(Pipe pipe) 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, getCredential, 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, xhiccuped, xjoin, xleave
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
-
subscriptions
-
manualSubscriptions
-
dist
-
verboseSubs
private boolean verboseSubs -
verboseUnsubs
private boolean verboseUnsubs -
more
private boolean more -
lossy
private boolean lossy -
manual
private boolean manual -
lastPipe
-
pendingPipes
-
pendingData
-
pendingFlags
-
markAsMatching
-
sendUnsubscription
-
-
Constructor Details
-
XPub
-
-
Method Details
-
xattachPipe
- Specified by:
xattachPipe
in classSocketBase
-
xreadActivated
- Overrides:
xreadActivated
in classSocketBase
-
xwriteActivated
- Overrides:
xwriteActivated
in classSocketBase
-
xsetsockopt
- Overrides:
xsetsockopt
in classSocketBase
-
xpipeTerminated
- Specified by:
xpipeTerminated
in classSocketBase
-
markAsMatching
-
xsend
- Overrides:
xsend
in classSocketBase
-
xhasOut
protected boolean xhasOut()- Overrides:
xhasOut
in classSocketBase
-
xrecv
- Overrides:
xrecv
in classSocketBase
-
xhasIn
protected boolean xhasIn()- Overrides:
xhasIn
in classSocketBase
-
sendUnsubscription
private void sendUnsubscription(byte[] data, int size)
-