Package org.apache.catalina.ha.backend

Class TcpSender

java.lang.Object

org.apache.catalina.ha.backend.TcpSender

All Implemented Interfaces:

Sender

public class TcpSender
extends Object
implements Sender

TCP-based sender for sending heartbeat messages to proxy servers.

Field Summary

Fields

Modifier and Type	Field	Description
protected BufferedReader[]	connectionReaders	Readers for active connections.
protected Socket[]	connections	Active socket connections to proxies.
protected BufferedWriter[]	connectionWriters	Writers for active connections.
protected Proxy[]	proxies	Proxies.

Constructor Summary

Constructors

Constructor	Description
TcpSender()	Constructs a new TcpSender.

Method Summary

Modifier and Type	Method	Description
protected void	close(int i)	Close connection.
void	init(HeartbeatListener config)	Set the configuration parameters
int	send(String mess)	Send the message to the proxies

Methods inherited from class java.lang.Object

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

Field Details

proxies

protected Proxy[] proxies

Proxies.

connections

protected Socket[] connections

Active socket connections to proxies.

connectionReaders

protected BufferedReader[] connectionReaders

Readers for active connections.

connectionWriters

protected BufferedWriter[] connectionWriters

Writers for active connections.

Constructor Details

TcpSender

public TcpSender()

Constructs a new TcpSender.

Method Details

init

public void init(HeartbeatListener config)
          throws Exception

Description copied from interface: Sender

Set the configuration parameters

Specified by:

init in interface Sender

Parameters:

config - The heartbeat listener configuration

Throws:

Exception - An error occurred

send

public int send(String mess)
         throws Exception

Description copied from interface: Sender

Send the message to the proxies

Specified by:

send in interface Sender

Parameters:

mess - The message that will be sent

Returns:

0 if no error occurred, -1 otherwise

Throws:

Exception - An error occurred

close

protected void close(int i)

Close connection.

Parameters:

i - The index of the connection that will be closed