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
public class XPub extends SocketBase
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description private static class
XPub.MarkAsMatching
private static class
XPub.SendUnsubscription
-
Field Summary
Fields Modifier and Type Field Description private Dist
dist
private Pipe
lastPipe
private boolean
lossy
private boolean
manual
private Mtrie
manualSubscriptions
private static Mtrie.IMtrieHandler
markAsMatching
private boolean
more
private java.util.Deque<Blob>
pendingData
private java.util.Deque<java.lang.Integer>
pendingFlags
private java.util.Deque<Pipe>
pendingPipes
private static Mtrie.IMtrieHandler
sendUnsubscription
private Mtrie
subscriptions
private boolean
verboseSubs
private boolean
verboseUnsubs
-
Fields inherited from class zmq.SocketBase
connectRid
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description private 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
xsend(Msg msg)
boolean
xsetsockopt(int option, java.lang.Object optval)
protected void
xwriteActivated(Pipe pipe)
-
Methods inherited from class zmq.SocketBase
bind, close, connect, destroy, errno, eventAccepted, eventAcceptFailed, eventBindFailed, eventClosed, eventCloseFailed, eventConnectDelayed, eventConnected, eventConnectRetried, eventDisconnected, eventHandshaken, eventListening, getCredential, getFD, getSocketOpt, getSocketOptx, hiccuped, inEvent, monitor, monitorEvent, pipeTerminated, processBind, processDestroy, processStop, processTerm, readActivated, recv, send, setSocketOpt, termEndpoint, toString, typeString, writeActivated, xhiccuped
-
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, processHiccup, processPipeTerm, processPipeTermAck, processPlug, processReap, processReaped, registerEndpoint, sendActivateRead, sendActivateWrite, sendAttach, sendAttach, sendBind, sendBind, sendDone, sendHiccup, sendInprocConnected, sendOwn, sendPipeTerm, sendPipeTermAck, sendPlug, sendPlug, sendReap, 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
-
subscriptions
private final Mtrie subscriptions
-
manualSubscriptions
private final Mtrie manualSubscriptions
-
dist
private final Dist dist
-
verboseSubs
private boolean verboseSubs
-
verboseUnsubs
private boolean verboseUnsubs
-
more
private boolean more
-
lossy
private boolean lossy
-
manual
private boolean manual
-
lastPipe
private Pipe lastPipe
-
pendingPipes
private final java.util.Deque<Pipe> pendingPipes
-
pendingData
private final java.util.Deque<Blob> pendingData
-
pendingFlags
private final java.util.Deque<java.lang.Integer> pendingFlags
-
markAsMatching
private static final Mtrie.IMtrieHandler markAsMatching
-
sendUnsubscription
private static final Mtrie.IMtrieHandler sendUnsubscription
-
-
Constructor Detail
-
XPub
public XPub(Ctx parent, int tid, int sid)
-
-
Method Detail
-
xattachPipe
protected void xattachPipe(Pipe pipe, boolean subscribeToAll, boolean isLocallyInitiated)
- Specified by:
xattachPipe
in classSocketBase
-
xreadActivated
protected void xreadActivated(Pipe pipe)
- Overrides:
xreadActivated
in classSocketBase
-
xwriteActivated
protected void xwriteActivated(Pipe pipe)
- Overrides:
xwriteActivated
in classSocketBase
-
xsetsockopt
public boolean xsetsockopt(int option, java.lang.Object optval)
- Overrides:
xsetsockopt
in classSocketBase
-
xpipeTerminated
protected void xpipeTerminated(Pipe pipe)
- Specified by:
xpipeTerminated
in classSocketBase
-
markAsMatching
private void markAsMatching(Pipe pipe)
-
xsend
protected boolean xsend(Msg msg)
- Overrides:
xsend
in classSocketBase
-
xhasOut
protected boolean xhasOut()
- Overrides:
xhasOut
in classSocketBase
-
xrecv
protected Msg xrecv()
- Overrides:
xrecv
in classSocketBase
-
xhasIn
protected boolean xhasIn()
- Overrides:
xhasIn
in classSocketBase
-
sendUnsubscription
private void sendUnsubscription(byte[] data, int size)
-
-