public static class Pub.PubSession extends XPub.XPubSession
Modifier and Type | Field and Description |
---|---|
protected Options |
options |
protected SocketBase |
socket |
Constructor and Description |
---|
PubSession(IOThread ioThread,
boolean connect,
SocketBase socket,
Options options,
Address addr) |
Modifier and Type | Method and Description |
---|---|
void |
acceptEvent() |
void |
attachPipe(zmq.Pipe pipe) |
void |
connectEvent() |
static zmq.SessionBase |
create(IOThread ioThread,
boolean connect,
SocketBase socket,
Options options,
Address addr) |
void |
destroy() |
void |
detach() |
void |
flush() |
SocketBase |
getSocket() |
void |
hiccuped(zmq.Pipe pipe) |
void |
inEvent() |
protected boolean |
isTerminating() |
protected void |
launchChild(zmq.Own object) |
void |
outEvent() |
void |
pipeTerminated(zmq.Pipe pipe) |
protected void |
processAttach(IEngine engine) |
protected void |
processDestroy() |
protected void |
processOwn(zmq.Own object) |
protected void |
processPlug() |
protected void |
processSeqnum() |
protected void |
processTerm(int linger) |
protected void |
processTermAck() |
protected void |
processTermReq(zmq.Own object) |
Msg |
pullMsg() |
int |
pushMsg(Msg msg) |
void |
readActivated(zmq.Pipe pipe) |
void |
registerTermAcks(int count) |
protected void |
reset() |
protected void |
termChild(zmq.Own object) |
protected void |
terminate() |
void |
timerEvent(int id) |
String |
toString() |
void |
unregisterTermAck() |
void |
writeActivated(zmq.Pipe pipe) |
chooseIoThread, destroySocket, findEndpoint, getCtx, getTid, processActivateRead, processActivateWrite, processBind, processCommand, processHiccup, processPipeTerm, processPipeTermAck, processReap, processReaped, processStop, registerEndpoint, sendActivateRead, sendActivateWrite, sendAttach, sendAttach, sendBind, sendBind, sendDone, sendHiccup, sendOwn, sendPipeTerm, sendPipeTermAck, sendPlug, sendPlug, sendReap, sendReaped, sendStop, sendTerm, sendTermAck, sendTermReq, unregisterEndpoints
protected SocketBase socket
protected final Options options
public PubSession(IOThread ioThread, boolean connect, SocketBase socket, Options options, Address addr)
public static zmq.SessionBase create(IOThread ioThread, boolean connect, SocketBase socket, Options options, Address addr)
public void destroy()
public void attachPipe(zmq.Pipe pipe)
public Msg pullMsg()
pullMsg
in interface IMsgSource
protected void reset()
public void flush()
public void pipeTerminated(zmq.Pipe pipe)
public void readActivated(zmq.Pipe pipe)
public void writeActivated(zmq.Pipe pipe)
public void hiccuped(zmq.Pipe pipe)
public SocketBase getSocket()
protected void processPlug()
processPlug
in class ZObject
protected void processAttach(IEngine engine)
processAttach
in class ZObject
public void detach()
protected void processTerm(int linger)
public void timerEvent(int id)
timerEvent
in interface IPollEvents
public void inEvent()
inEvent
in interface IPollEvents
public void outEvent()
outEvent
in interface IPollEvents
public void connectEvent()
connectEvent
in interface IPollEvents
public void acceptEvent()
acceptEvent
in interface IPollEvents
protected void processDestroy()
protected void processSeqnum()
processSeqnum
in class ZObject
protected void launchChild(zmq.Own object)
protected void termChild(zmq.Own object)
protected void processTermReq(zmq.Own object)
processTermReq
in class ZObject
protected void processOwn(zmq.Own object)
processOwn
in class ZObject
protected void terminate()
protected boolean isTerminating()
public void registerTermAcks(int count)
public void unregisterTermAck()
protected void processTermAck()
processTermAck
in class ZObject
Copyright © 2016. All rights reserved.