Field Summary
private ConcurrentHashMap	acceptingChannels
protected final static String	className
private ConcurrentHashMap	listeningChannels
private ReentrantLock	lock
protected static Logger	logger
private LinkedList	openChannels
private ConcurrentHashMap	pendingConnections
ServerSocketChannel	channel
ConnectionListener	connectionListener
int	counter
TcpChannelEndpoint	localEndpoint

Constructor Summary
void	ServerChannel(TcpChannelEndpoint endpoint, ConnectionListener listener, Integer count)
void	TcpStreamAccessPoint(String name, ChannelAccessPointConfig capConfig)

Method Summary
protected void	closeChannel(TcpStreamChannel channel)
public ChannelEndpoint	getEndpoint(String text)
protected SelectorThread	getSelectorThread()
public void	listen(ChannelEndpoint localEndpoint, ConnectionListener connectionListener, Integer numberOfConnections)
public void	onAccept(SelectableChannel channel)
public void	onConnect(SelectableChannel channel)
public CommChannel	openChannel(ChannelEndpoint remoteEndpoint, CommChannelListener dataListener)
public CommChannel	openChannel(ChannelEndpoint remoteEndpoint, Integer timeout)
public CommChannel	openChannel(ChannelEndpoint remoteEndpoint, CommChannelStateListener connectionListener)
public void	stopListening(ChannelEndpoint localEndpoint)

Field Detail

acceptingChannels

private ConcurrentHashMap acceptingChannels

Multiplicity:

className

protected final static String className

Final.

Multiplicity:

Static.

listeningChannels

private ConcurrentHashMap listeningChannels

Multiplicity:

lock

private ReentrantLock lock

Multiplicity:

logger

protected static Logger logger

Multiplicity:

Static.

openChannels

private LinkedList openChannels

Multiplicity:

pendingConnections

private ConcurrentHashMap pendingConnections

Multiplicity:

Constructor Detail

TcpStreamAccessPoint

void TcpStreamAccessPoint (String name, ChannelAccessPointConfig capConfig)

Parameters:

name
capConfig

Stereotype:

create

Method Detail

closeChannel

protected void closeChannel (TcpStreamChannel channel)

Parameters:

channel

getEndpoint

public ChannelEndpoint getEndpoint (String text)

Throws:

IOException

getSelectorThread

protected SelectorThread getSelectorThread ()

Return:

this access point's selector thread

listen

public void listen (ChannelEndpoint localEndpoint, ConnectionListener connectionListener, Integer numberOfConnections)

Throws:

IOException

onAccept

public void onAccept (SelectableChannel channel)

onConnect

public void onConnect (SelectableChannel channel)

openChannel

public CommChannel openChannel (ChannelEndpoint remoteEndpoint, CommChannelListener dataListener)

Syncrhonously opens and connects a tcp channel to the remote endpoint

Parameters:

remoteEndpoint
endpoint to connect to
dataListener
listener to be notified on incomming data

Return:

newly opened and connected tcp channel

Throws:

IOException

openChannel

public CommChannel openChannel (ChannelEndpoint remoteEndpoint, Integer timeout)

Syncrhonously opens and connects a tcp channel to the remote endpoint

Parameters:

remoteEndpoint
endpoint to connect to
timeout
milliseconds to wait for the channel to get connected

Return:

newly opened and connected tcp channel

Throws:

IOException

openChannel

public CommChannel openChannel (ChannelEndpoint remoteEndpoint, CommChannelStateListener connectionListener)

Asyncrhonously opens a tcp channel and notifies connection listener upon establishing the
connection to the remote endpoint. registerStreamListener must be invoked on the channel upon
connection in order to be notified of incomming data.

Parameters:

remoteEndpoint
endpoint to connect to
connectionListener
listener to be notified on connection

Return:

newly opened tcp channel

Throws:

IOException

stopListening

public void stopListening (ChannelEndpoint localEndpoint)