| Modifier and Type | Field and Description | 
|---|---|
| protected java.io.BufferedReader[] | connectionReaders | 
| protected java.net.Socket[] | connectionsActive connections. | 
| protected java.io.BufferedWriter[] | connectionWriters | 
| protected Proxy[] | proxiesProxies. | 
| Constructor and Description | 
|---|
| TcpSender() | 
| Modifier and Type | Method and Description | 
|---|---|
| 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 | 
protected Proxy[] proxies
protected java.net.Socket[] connections
protected java.io.BufferedReader[] connectionReaders
protected java.io.BufferedWriter[] connectionWriters
public void init(HeartbeatListener config) throws java.lang.Exception
Senderpublic int send(java.lang.String mess)
         throws java.lang.Exception
Senderprotected void close(int i)
Copyright © 2000-2015 Apache Software Foundation. All Rights Reserved.