zmq

Class TcpListener

java.lang.Object

zmq.ZObject

zmq.Own

zmq.TcpListener

All Implemented Interfaces:

IPollEvents

Direct Known Subclasses:

IpcListener

public class TcpListener
extends Own
implements IPollEvents

Field Summary

Fields

Modifier and Type	Field and Description
private TcpAddress	address
private java.lang.String	endpoint
private java.nio.channels.ServerSocketChannel	handle
private IOObject	ioObject
private static boolean	isWindows
private SocketBase	socket

Fields inherited from class zmq.Own

options

Constructor Summary

Constructors

Constructor and Description
TcpListener(IOThread ioThread, SocketBase socket, Options options)

Method Summary

Modifier and Type	Method and Description
private java.nio.channels.SocketChannel	accept()
void	acceptEvent()
private void	close()
void	connectEvent()
void	destroy()
java.lang.String	getAddress()
void	inEvent()
void	outEvent()
protected void	processPlug()
protected void	processTerm(int linger)
int	setAddress(java.lang.String addr)
void	timerEvent(int id)

Methods inherited from class zmq.Own

incSeqnum, isTerminating, launchChild, processDestroy, processOwn, processSeqnum, processTermAck, processTermReq, registerTermAcks, termChild, terminate, unregisterTermAck

Methods inherited from class zmq.ZObject

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

Methods inherited from class java.lang.Object

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

Field Detail

isWindows

private static boolean isWindows

address

private final TcpAddress address

handle

private java.nio.channels.ServerSocketChannel handle

socket

private SocketBase socket

endpoint

private java.lang.String endpoint

ioObject

private final IOObject ioObject

Constructor Detail

TcpListener

public TcpListener(IOThread ioThread,
                   SocketBase socket,
                   Options options)

Method Detail

destroy

public void destroy()

Specified by:

destroy in class Own

processPlug

protected void processPlug()

Overrides:

processPlug in class ZObject

processTerm

protected void processTerm(int linger)

Overrides:

processTerm in class Own

acceptEvent

public void acceptEvent()

Specified by:

acceptEvent in interface IPollEvents

close

private void close()

getAddress

public java.lang.String getAddress()

setAddress

public int setAddress(java.lang.String addr)

accept

private java.nio.channels.SocketChannel accept()

inEvent

public void inEvent()

Specified by:

inEvent in interface IPollEvents

outEvent

public void outEvent()

Specified by:

outEvent in interface IPollEvents

connectEvent

public void connectEvent()

Specified by:

connectEvent in interface IPollEvents

timerEvent

public void timerEvent(int id)

Specified by:

timerEvent in interface IPollEvents