Modifier and Type | Field | Description |
---|---|---|
protected java.io.BufferedReader[] |
connectionReaders |
|
protected java.net.Socket[] |
connections |
Active connections.
|
protected java.io.BufferedWriter[] |
connectionWriters |
|
protected Proxy[] |
proxies |
Proxies.
|
Constructor | Description |
---|---|
TcpSender() |
Modifier and Type | Method | 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
Sender
public int send(java.lang.String mess) throws java.lang.Exception
Sender
protected void close(int i)
i
- The index of the connection that will be closedCopyright © 2000-2019 Apache Software Foundation. All Rights Reserved.