Package zmq.socket.pipeline
Class Push
- java.lang.Object
-
- zmq.ZObject
-
- zmq.Own
-
- zmq.SocketBase
-
- zmq.socket.pipeline.Push
-
- All Implemented Interfaces:
Pipe.IPipeEvents
,IPollEvents
public class Push extends SocketBase
-
-
Field Summary
Fields Modifier and Type Field Description private LB
lb
-
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 subscribe2all, boolean isLocallyInitiated)
protected boolean
xhasOut()
protected void
xpipeTerminated(Pipe pipe)
boolean
xsend(Msg msg)
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, xhasIn, xhiccuped, xreadActivated, xrecv, xsetsockopt
-
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
-
lb
private final LB lb
-
-
Constructor Detail
-
Push
public Push(Ctx parent, int tid, int sid)
-
-
Method Detail
-
xattachPipe
protected void xattachPipe(Pipe pipe, boolean subscribe2all, boolean isLocallyInitiated)
- Specified by:
xattachPipe
in classSocketBase
-
xwriteActivated
protected void xwriteActivated(Pipe pipe)
- Overrides:
xwriteActivated
in classSocketBase
-
xpipeTerminated
protected void xpipeTerminated(Pipe pipe)
- Specified by:
xpipeTerminated
in classSocketBase
-
xsend
public boolean xsend(Msg msg)
- Overrides:
xsend
in classSocketBase
-
xhasOut
protected boolean xhasOut()
- Overrides:
xhasOut
in classSocketBase
-
-