Package zmq.socket.radiodish
Class Radio.RadioSession
- java.lang.Object
-
- zmq.ZObject
-
- zmq.Own
-
- zmq.io.SessionBase
-
- zmq.socket.radiodish.Radio.RadioSession
-
- All Implemented Interfaces:
Pipe.IPipeEvents
,IPollEvents
- Enclosing class:
- Radio
public static class Radio.RadioSession extends SessionBase
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description (package private) static class
Radio.RadioSession.State
-
Field Summary
Fields Modifier and Type Field Description private Msg
pending
private Radio.RadioSession.State
state
-
Fields inherited from class zmq.io.SessionBase
socket
-
-
Constructor Summary
Constructors Constructor Description RadioSession(IOThread ioThread, boolean connect, SocketBase socket, Options options, Address addr)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected Msg
pullMsg()
boolean
pushMsg(Msg msg)
protected void
reset()
-
Methods inherited from class zmq.io.SessionBase
attachPipe, destroy, engineError, flush, getEndpoint, getSocket, hiccuped, incSeqnum, pipeTerminated, processAttach, processPlug, processTerm, readActivated, readZapMsg, timerEvent, toString, writeActivated, writeZapMsg, zapConnect, zapEnabled
-
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 Detail
-
state
private Radio.RadioSession.State state
-
pending
private Msg pending
-
-
Constructor Detail
-
RadioSession
public RadioSession(IOThread ioThread, boolean connect, SocketBase socket, Options options, Address addr)
-
-
Method Detail
-
pushMsg
public boolean pushMsg(Msg msg)
- Overrides:
pushMsg
in classSessionBase
-
pullMsg
protected Msg pullMsg()
- Overrides:
pullMsg
in classSessionBase
-
reset
protected void reset()
- Overrides:
reset
in classSessionBase
-
-