Package zmq.socket.radiodish
Class Dish.DishSession
java.lang.Object
zmq.ZObject
zmq.Own
zmq.io.SessionBase
zmq.socket.radiodish.Dish.DishSession
- All Implemented Interfaces:
Pipe.IPipeEvents
,IPollEvents
- Enclosing class:
Dish
-
Nested Class Summary
Nested Classes -
Field Summary
FieldsModifier and TypeFieldDescriptionprivate String
(package private) static final byte[]
(package private) static final byte[]
private Dish.DishSession.State
Fields inherited from class zmq.io.SessionBase
socket
-
Constructor Summary
ConstructorsConstructorDescriptionDishSession
(IOThread ioThread, boolean connect, SocketBase socket, Options options, Address addr) -
Method Summary
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 Details
-
JOIN_BYTES
static final byte[] JOIN_BYTES -
LEAVE_BYTES
static final byte[] LEAVE_BYTES -
state
-
group
-
-
Constructor Details
-
DishSession
public DishSession(IOThread ioThread, boolean connect, SocketBase socket, Options options, Address addr)
-
-
Method Details
-
pushMsg
- Overrides:
pushMsg
in classSessionBase
-
pullMsg
- Overrides:
pullMsg
in classSessionBase
-
reset
protected void reset()- Overrides:
reset
in classSessionBase
-