Field Summary
private String	accesPointName
protected final static String	className
private final static long	CONNECTION_RETRY_INTERVAL
protected HashMap	establishedChannels
protected HashMap	halfChannels
protected int	hostId
RttAccessPoint	accessPoint
ConnectionListener	connectionListener
int	counter
RttEndpoint	localEndpoint
TimerTask	retryListeningPrimary
TimerTask	retryListeningSecondary
ReentrantLock	retryLock
private HashMap	listeningServers
protected ReentrantLock	lock
protected static Logger	logger
protected HashMap	reconnectingChannels
private Timer	rttTimer
protected TcpStreamAccessPoint	tcpStreamAccessPoint

Constructor Summary
protected void	ListeningServer(RttEndpoint endpoint, ConnectionListener listener, Integer count)
void	RttAccessPoint(String name, ChannelAccessPointConfig capConfig)

Method Summary
void	closeChannel(RttChannel channel)
protected boolean	connectChannel(RttClientChannel rc, RttEndpoint remoteEndpoint, MessageListener messageListener)
public ChannelEndpoint	getEndpoint(String text)
private void	initializeTimer()
public void	listen(ChannelEndpoint localEndpoint, ConnectionListener connectionListener, Integer numberOfConnections)
private void	accept(RttServerChannel channel)
protected synchronized void	decrementConnectCounter()
protected synchronized void	incrementConnectCounter()
protected void	listen()
public void	newConnection(CommChannel channel)
protected void	register(RttServerChannel channel)
protected void	reWire(RttServerChannel channel)
protected void	stop()
public CommChannel	openChannel(ChannelEndpoint remoteEndpoint, CommChannelStateListener connectionListener)
public CommChannel	openChannel(ChannelEndpoint remoteEndpoint, Integer timeout)
public CommChannel	openChannel(ChannelEndpoint remoteEndpoint, CommChannelListener dataListener)
void	reConnect(RttChannel channel, TcpStreamChannel tcpChannel, Boolean primary)
private Thread	retryConnection(RttClientChannel channel, TcpChannelEndpoint endpoint, Boolean primary)
void	scheduleHeartbeat(TimerTask tt)
public void	stopListening(ChannelEndpoint localEndpoint)

Field Detail

accesPointName

private String accesPointName

Multiplicity:

className

protected final static String className

Final.

Multiplicity:

Static.

CONNECTION_RETRY_INTERVAL

private final static long CONNECTION_RETRY_INTERVAL

Final.

Multiplicity:

Static.

establishedChannels

protected HashMap establishedChannels

Multiplicity:

halfChannels

protected HashMap halfChannels

Multiplicity:

hostId

protected int hostId

Multiplicity:

listeningServers

private HashMap listeningServers

Multiplicity:

lock

protected ReentrantLock lock

Multiplicity:

logger

protected static Logger logger

Multiplicity:

Static.

reconnectingChannels

protected HashMap reconnectingChannels

Multiplicity:

rttTimer

private Timer rttTimer

Multiplicity:

tcpStreamAccessPoint

protected TcpStreamAccessPoint tcpStreamAccessPoint

Multiplicity:

Constructor Detail

RttAccessPoint

void RttAccessPoint (String name, ChannelAccessPointConfig capConfig)

Stereotype:

create

Method Detail

closeChannel

void closeChannel (RttChannel channel)

Cleans up the resources after the channel. Invoked from within the RttChannel.close()

Parameters:

channel
the closing channel

connectChannel

protected boolean connectChannel (RttClientChannel rc, RttEndpoint remoteEndpoint, MessageListener messageListener)

Helper operation used by several openChannel methods to actualy connect the channel after all
the checks have been made

Parameters:

rc
RttClientChannel to connect
remoteEndpoint
where to connect it
messageListener
an optional message listener to be set upon connection

Return:

true for full or partial success, false if both tcp channels failed

getEndpoint

public ChannelEndpoint getEndpoint (String text)

Throws:

IOException

initializeTimer

private void initializeTimer ()

Creates a timer and schedules a dummy timer task for immediate execution in order to raise
the priority of the timer thread to its groups max priority

listen

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

Throws:

IOException

openChannel

public CommChannel openChannel (ChannelEndpoint remoteEndpoint, CommChannelStateListener connectionListener)

Throws:

IOException

openChannel

public CommChannel openChannel (ChannelEndpoint remoteEndpoint, Integer timeout)

Throws:

IOException

openChannel

public CommChannel openChannel (ChannelEndpoint remoteEndpoint, CommChannelListener dataListener)

Throws:

IOException

reConnect

void reConnect (RttChannel channel, TcpStreamChannel tcpChannel, Boolean primary)

Tries to establish a lost connection on one of the redundant tcp channels by either
reconnecting the client channel or starting to listen for connection retry on a server
channel

Parameters:

channel
tcpChannel
primary

retryConnection

private Thread retryConnection (RttClientChannel channel, TcpChannelEndpoint endpoint, Boolean primary)

Creates a thread which periodically tries to connect the failed tcp channel

Parameters:

channel
RttClientChannel to retry the connection for
endpoint
TcpChannelEndpoint to connect
primary
true if primary tcp channel, false if secondary

scheduleHeartbeat

void scheduleHeartbeat (TimerTask tt)

Schedules a heartbeat timer task

Parameters:

tt
heartbeat timer task