Modifier and Type | Field and Description |
---|---|
protected java.io.BufferedReader[] |
connectionReaders |
protected java.net.Socket[] |
connections
Active connections.
|
protected java.io.BufferedWriter[] |
connectionWriters |
protected Proxy[] |
proxies
Proxies.
|
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
Sender
public int send(java.lang.String mess) throws java.lang.Exception
Sender
protected void close(int i)
Copyright © 2000-2018 Apache Software Foundation. All Rights Reserved.