public class TcpListener extends ZObject implements IPollEvents
Constructor and Description |
---|
TcpListener(IOThread ioThread,
SocketBase socket,
Options options) |
Modifier and Type | Method and Description |
---|---|
void |
acceptEvent() |
void |
connectEvent() |
void |
destroy() |
String |
getAddress() |
void |
inEvent() |
protected boolean |
isTerminating() |
protected void |
launchChild(zmq.Own object) |
void |
outEvent() |
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) |
void |
registerTermAcks(int count) |
int |
setAddress(String addr) |
protected void |
termChild(zmq.Own object) |
protected void |
terminate() |
void |
timerEvent(int id) |
void |
unregisterTermAck() |
chooseIoThread, destroySocket, findEndpoint, getCtx, getTid, processActivateRead, processActivateWrite, processAttach, 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 final Options options
public TcpListener(IOThread ioThread, SocketBase socket, Options options)
public void destroy()
protected void processPlug()
processPlug
in class ZObject
protected void processTerm(int linger)
public void acceptEvent()
acceptEvent
in interface IPollEvents
public String getAddress()
public int setAddress(String addr)
public void inEvent()
inEvent
in interface IPollEvents
public void outEvent()
outEvent
in interface IPollEvents
public void connectEvent()
connectEvent
in interface IPollEvents
public void timerEvent(int id)
timerEvent
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 © 2021. All rights reserved.