Package zmq.socket
Class Stream
- java.lang.Object
-
- zmq.ZObject
-
- zmq.Own
-
- zmq.SocketBase
-
- zmq.socket.Stream
-
- All Implemented Interfaces:
Pipe.IPipeEvents
,IPollEvents
public class Stream extends SocketBase
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description private class
Stream.Outpipe
-
Field Summary
Fields Modifier and Type Field Description private Pipe
currentOut
private FQ
fq
private boolean
identitySent
private boolean
moreOut
private int
nextRid
private java.util.Map<Blob,Stream.Outpipe>
outpipes
private boolean
prefetched
private Msg
prefetchedId
private Msg
prefetchedMsg
-
Fields inherited from class zmq.SocketBase
connectRid
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description private void
identifyPeer(Pipe pipe, boolean isLocallyInitiated)
protected void
xattachPipe(Pipe pipe, boolean icanhasall, boolean isLocallyInitiated)
protected boolean
xhasIn()
protected boolean
xhasOut()
protected void
xpipeTerminated(Pipe pipe)
protected void
xreadActivated(Pipe pipe)
Msg
xrecv()
protected boolean
xsend(Msg msg)
protected 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
-
fq
private final FQ fq
-
prefetched
private boolean prefetched
-
identitySent
private boolean identitySent
-
prefetchedId
private Msg prefetchedId
-
prefetchedMsg
private Msg prefetchedMsg
-
outpipes
private java.util.Map<Blob,Stream.Outpipe> outpipes
-
currentOut
private Pipe currentOut
-
moreOut
private boolean moreOut
-
nextRid
private int nextRid
-
-
Constructor Detail
-
Stream
public Stream(Ctx parent, int tid, int sid)
-
-
Method Detail
-
xattachPipe
protected void xattachPipe(Pipe pipe, boolean icanhasall, boolean isLocallyInitiated)
- Specified by:
xattachPipe
in classSocketBase
-
xpipeTerminated
protected void xpipeTerminated(Pipe pipe)
- Specified by:
xpipeTerminated
in classSocketBase
-
xreadActivated
protected void xreadActivated(Pipe pipe)
- Overrides:
xreadActivated
in classSocketBase
-
xwriteActivated
protected void xwriteActivated(Pipe pipe)
- Overrides:
xwriteActivated
in classSocketBase
-
xsend
protected boolean xsend(Msg msg)
- Overrides:
xsend
in classSocketBase
-
xsetsockopt
protected boolean xsetsockopt(int option, java.lang.Object optval)
- Overrides:
xsetsockopt
in classSocketBase
-
xrecv
public Msg xrecv()
- Overrides:
xrecv
in classSocketBase
-
xhasIn
protected boolean xhasIn()
- Overrides:
xhasIn
in classSocketBase
-
xhasOut
protected boolean xhasOut()
- Overrides:
xhasOut
in classSocketBase
-
identifyPeer
private void identifyPeer(Pipe pipe, boolean isLocallyInitiated)
-
-