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 enum	Dish.DishSession.State

Field Summary

Fields

Modifier and Type	Field	Description
private String	group
(package private) static final byte[]	JOIN_BYTES
(package private) static final byte[]	LEAVE_BYTES
private Dish.DishSession.State	state

Fields inherited from class SessionBase

socket

Fields inherited from class Own

errno, options

Constructor Summary

Constructors

Constructor	Description
DishSession(IOThread ioThread, boolean connect, SocketBase socket, Options options, Address addr)

Method Summary

Modifier and Type	Method	Description
protected Msg	pullMsg()
boolean	pushMsg(Msg msg)
protected void	reset()

Methods inherited from class 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 Own

isTerminating, launchChild, processDestroy, processOwn, processSeqnum, processTermAck, processTermReq, termChild, terminate

Methods inherited from class 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 Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface IPollEvents

acceptEvent, connectEvent, inEvent, outEvent

Field Details

JOIN_BYTES

static final byte[] JOIN_BYTES

LEAVE_BYTES

static final byte[] LEAVE_BYTES

state

private Dish.DishSession.State state

group

private String group

Constructor Details

DishSession

public DishSession(IOThread ioThread,
 boolean connect,
 SocketBase socket,
 Options options,
 Address addr)

Method Details

pushMsg

public boolean pushMsg(Msg msg)

Overrides:

pushMsg in class SessionBase

pullMsg

protected Msg pullMsg()

Overrides:

pullMsg in class SessionBase

reset

protected void reset()

Overrides:

reset in class SessionBase