Field Detail

• proxies

  protected Proxy[] proxies

  Proxies.

• connections

  protected Socket[] connections

  Active connections.

• connectionReaders

  protected BufferedReader[] connectionReaders

• connectionWriters

  protected BufferedWriter[] connectionWriters

Constructor Detail

• TcpSender

  public TcpSender()

Method Detail

• 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