Package zmq.io.net.tcp
Class TcpListener
- java.lang.Object
-
- zmq.ZObject
-
- zmq.Own
-
- zmq.io.net.Listener
-
- zmq.io.net.tcp.TcpListener
-
- All Implemented Interfaces:
IPollEvents
- Direct Known Subclasses:
IpcListener
,TipcListener
public class TcpListener extends Listener
-
-
Field Summary
Fields Modifier and Type Field Description private TcpAddress
address
private java.lang.String
endpoint
private java.nio.channels.ServerSocketChannel
fd
private Poller.Handle
handle
private IOObject
ioObject
private static boolean
isWindows
-
Constructor Summary
Constructors Constructor Description TcpListener(IOThread ioThread, SocketBase socket, Options options)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description private java.nio.channels.SocketChannel
accept()
void
acceptEvent()
Called by I/O thread when file descriptor is ready for accept.protected java.lang.String
address(Address.IZAddress address)
private void
close()
void
destroy()
java.lang.String
getAddress()
protected void
processPlug()
protected void
processTerm(int linger)
private boolean
setAddress()
boolean
setAddress(java.lang.String addr)
protected boolean
setAddress(java.net.InetSocketAddress addr)
java.lang.String
toString()
-
Methods inherited from class zmq.Own
incSeqnum, isTerminating, launchChild, processDestroy, processOwn, processSeqnum, processTermAck, processTermReq, termChild, terminate
-
Methods inherited from class zmq.ZObject
chooseIoThread, connectPending, destroySocket, findEndpoint, getCtx, getTid, pendConnection, processActivateRead, processActivateWrite, processAttach, 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
connectEvent, inEvent, outEvent, timerEvent
-
-
-
-
Field Detail
-
isWindows
private static final boolean isWindows
-
address
private TcpAddress address
-
fd
private java.nio.channels.ServerSocketChannel fd
-
handle
private Poller.Handle handle
-
endpoint
private java.lang.String endpoint
-
ioObject
private final IOObject ioObject
-
-
Constructor Detail
-
TcpListener
public TcpListener(IOThread ioThread, SocketBase socket, Options options)
-
-
Method Detail
-
processPlug
protected void processPlug()
- Overrides:
processPlug
in classZObject
-
processTerm
protected void processTerm(int linger)
- Overrides:
processTerm
in classOwn
-
acceptEvent
public void acceptEvent()
Description copied from interface:IPollEvents
Called by I/O thread when file descriptor is ready for accept.
-
close
private void close()
-
getAddress
public java.lang.String getAddress()
- Specified by:
getAddress
in classListener
-
address
protected java.lang.String address(Address.IZAddress address)
-
setAddress
public boolean setAddress(java.lang.String addr)
- Specified by:
setAddress
in classListener
-
setAddress
protected boolean setAddress(java.net.InetSocketAddress addr)
-
setAddress
private boolean setAddress()
-
accept
private java.nio.channels.SocketChannel accept() throws java.io.IOException
- Throws:
java.io.IOException
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-