org.apache.catalina.ha.backend
Class TcpSender

java.lang.Object
  org.apache.catalina.ha.backend.TcpSender

All Implemented Interfaces:

Sender

public class TcpSender
extends java.lang.Object
implements Sender

Field Summary

protected java.io.BufferedReader[]	connectionReaders
protected java.net.Socket[]	connections Active connections.
protected java.io.BufferedWriter[]	connectionWriters
protected Proxy[]	proxies Proxies.

Constructor Summary

TcpSender()

Method Summary

protected void	close(int i) Close connection.
void	init(HeartbeatListener config) Set the configuration parameters
int	send(java.lang.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 Detail

proxies

protected Proxy[] proxies

Proxies.

connections

protected java.net.Socket[] connections

Active connections.

connectionReaders

protected java.io.BufferedReader[] connectionReaders

connectionWriters

protected java.io.BufferedWriter[] connectionWriters

Constructor Detail

TcpSender

public TcpSender()

Method Detail

init

public void init(HeartbeatListener config)
          throws java.lang.Exception

Description copied from interface: Sender

Set the configuration parameters

Specified by:

init in interface Sender

Throws:

java.lang.Exception

send

public int send(java.lang.String mess)
         throws java.lang.Exception

Description copied from interface: Sender

Send the message to the proxies

Specified by:

send in interface Sender

Throws:

java.lang.Exception

close

protected void close(int i)

Close connection.