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
public static class Dish.DishSession extends SessionBase
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description (package private) static class
Dish.DishSession.State
-
Field Summary
Fields Modifier and Type Field Description private java.lang.String
group
(package private) static byte[]
JOIN_BYTES
(package private) static byte[]
LEAVE_BYTES
private Dish.DishSession.State
state
-
Fields inherited from class zmq.io.SessionBase
socket
-
-
Constructor Summary
Constructors Constructor Description DishSession(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
-
JOIN_BYTES
static final byte[] JOIN_BYTES
-
LEAVE_BYTES
static final byte[] LEAVE_BYTES
-
state
private Dish.DishSession.State state
-
group
private java.lang.String group
-
-
Constructor Detail
-
DishSession
public DishSession(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
-
-