Package zmq.socket.pubsub
Class Pub
- java.lang.Object
-
- zmq.ZObject
-
- zmq.Own
-
- zmq.SocketBase
-
- zmq.socket.pubsub.XPub
-
- zmq.socket.pubsub.Pub
-
- All Implemented Interfaces:
Pipe.IPipeEvents
,IPollEvents
public class Pub extends XPub
-
-
Field Summary
-
Fields inherited from class zmq.SocketBase
connectRid
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
xattachPipe(Pipe pipe, boolean subscribeToAll, boolean isLocallyInitiated)
protected boolean
xhasIn()
protected Msg
xrecv()
-
Methods inherited from class zmq.socket.pubsub.XPub
xhasOut, xpipeTerminated, xreadActivated, xsend, xsetsockopt, xwriteActivated
-
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
-
-
-
-
Constructor Detail
-
Pub
public Pub(Ctx parent, int tid, int sid)
-
-