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

public class SessionBase
extends Own
implements Pipe.IPipeEvents, IPollEvents

Field Summary

Fields

Modifier and Type	Field	Description
protected final SocketBase	socket

Fields inherited from class Own

errno, options

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	attachPipe(Pipe pipe)
void	destroy()
void	engineError(boolean handshaked, StreamEngine.ErrorReason reason)
void	flush()
String	getEndpoint()
SocketBase	getSocket()
void	hiccuped(Pipe pipe)
final void	incSeqnum()
void	pipeTerminated(Pipe pipe)
protected void	processAttach(IEngine engine)
protected void	processPlug()
protected void	processTerm(int linger)
protected Msg	pullMsg()
protected boolean	pushMsg(Msg msg)
void	readActivated(Pipe pipe)
Msg	readZapMsg()
protected void	reset()
void	timerEvent(int id)	Called when timer expires.
String	toString()
void	writeActivated(Pipe pipe)
boolean	writeZapMsg(Msg msg)
int	zapConnect()
protected boolean	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

socket

protected final SocketBase socket

Constructor Details

SessionBase

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

Method Details

destroy

public void destroy()

Specified by:

destroy in class Own

attachPipe

public void attachPipe(Pipe pipe)

pullMsg

protected Msg pullMsg()

pushMsg

protected boolean pushMsg(Msg msg)

readZapMsg

public Msg readZapMsg()

writeZapMsg

public boolean writeZapMsg(Msg msg)

reset

protected void reset()

flush

public void flush()

pipeTerminated

public void pipeTerminated(Pipe pipe)

Specified by:

pipeTerminated in interface Pipe.IPipeEvents

readActivated

public void readActivated(Pipe pipe)

Specified by:

readActivated in interface Pipe.IPipeEvents

writeActivated

public void writeActivated(Pipe pipe)

Specified by:

writeActivated in interface Pipe.IPipeEvents

hiccuped

public void hiccuped(Pipe pipe)

Specified by:

hiccuped in interface Pipe.IPipeEvents

getSocket

public SocketBase getSocket()

processPlug

protected void processPlug()

Overrides:

processPlug in class ZObject

zapConnect

public int zapConnect()

zapEnabled

protected boolean zapEnabled()

processAttach

protected void processAttach(IEngine engine)

Overrides:

processAttach in class ZObject

engineError

public void engineError(boolean handshaked,
 StreamEngine.ErrorReason reason)

processTerm

protected void processTerm(int linger)

Overrides:

processTerm in class Own

timerEvent

public void timerEvent(int id)

Description copied from interface: IPollEvents

Called when timer expires.

Specified by:

timerEvent in interface IPollEvents

Parameters:

id - the ID of the expired timer.

getEndpoint

public String getEndpoint()

toString

public String toString()

Overrides:

toString in class Object

incSeqnum

public final void incSeqnum()

Overrides:

incSeqnum in class Own