Package zmq.io
Class SessionBase
java.lang.Object
zmq.ZObject
zmq.Own
zmq.io.SessionBase
- All Implemented Interfaces:
Pipe.IPipeEvents
,IPollEvents
- Direct Known Subclasses:
Dish.DishSession
,HelloMsgSession
,Radio.RadioSession
,Req.ReqSession
-
Field Summary
Fields -
Constructor Summary
ConstructorsConstructorDescriptionSessionBase
(IOThread ioThread, boolean connect, SocketBase socket, Options options, Address addr) -
Method Summary
Modifier and TypeMethodDescriptionvoid
attachPipe
(Pipe pipe) private void
void
destroy()
void
engineError
(boolean handshaked, StreamEngine.ErrorReason reason) void
flush()
void
final void
void
pipeTerminated
(Pipe pipe) protected void
processAttach
(IEngine engine) protected void
protected void
processTerm
(int linger) protected Msg
pullMsg()
protected boolean
void
readActivated
(Pipe pipe) private void
protected void
reset()
private void
startConnecting
(boolean wait) void
timerEvent
(int id) Called when timer expires.toString()
void
writeActivated
(Pipe pipe) boolean
writeZapMsg
(Msg msg) int
protected boolean
Methods inherited from class zmq.Own
isTerminating, launchChild, processDestroy, processOwn, processSeqnum, processTermAck, processTermReq, termChild, terminate
Methods inherited from class zmq.ZObject
chooseIoThread, connectPending, destroySocket, findEndpoint, getCtx, getTid, pendConnection, processActivateRead, processActivateWrite, processBind, processCancel, processHiccup, processPipeTerm, processPipeTermAck, processReap, processReapAck, processReaped, processStop, 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, inEvent, outEvent
-
Field Details
-
active
private final boolean active -
pipe
-
zapPipe
-
terminatingPipes
-
incompleteIn
private boolean incompleteIn -
pending
private boolean pending -
engine
-
socket
-
ioThread
-
LINGER_TIMER_ID
private static final int LINGER_TIMER_ID- See Also:
-
hasLingerTimer
private boolean hasLingerTimer -
addr
-
ioObject
-
-
Constructor Details
-
SessionBase
public SessionBase(IOThread ioThread, boolean connect, SocketBase socket, Options options, Address addr)
-
-
Method Details
-
destroy
public void destroy() -
attachPipe
-
pullMsg
-
pushMsg
-
readZapMsg
-
writeZapMsg
-
reset
protected void reset() -
flush
public void flush() -
cleanPipes
private void cleanPipes() -
pipeTerminated
- Specified by:
pipeTerminated
in interfacePipe.IPipeEvents
-
readActivated
- Specified by:
readActivated
in interfacePipe.IPipeEvents
-
writeActivated
- Specified by:
writeActivated
in interfacePipe.IPipeEvents
-
hiccuped
- Specified by:
hiccuped
in interfacePipe.IPipeEvents
-
getSocket
-
processPlug
protected void processPlug()- Overrides:
processPlug
in classZObject
-
zapConnect
public int zapConnect() -
zapEnabled
protected boolean zapEnabled() -
processAttach
- Overrides:
processAttach
in classZObject
-
engineError
-
processTerm
protected void processTerm(int linger) - Overrides:
processTerm
in classOwn
-
timerEvent
public void timerEvent(int id) Description copied from interface:IPollEvents
Called when timer expires.- Specified by:
timerEvent
in interfaceIPollEvents
- Parameters:
id
- the ID of the expired timer.
-
reconnect
private void reconnect() -
startConnecting
private void startConnecting(boolean wait) -
getEndpoint
-
toString
-
incSeqnum
public final void incSeqnum()
-