org.apache.catalina.tribes.transport.bio
public class BioSender extends AbstractSender implements DataSender
Since: 5.5.16
Version: $Revision: 532608 $ $Date: 2007-04-26 06:58:20 +0200 (Thu, 26 Apr 2007) $
Field Summary | |
---|---|
protected XByteBuffer | ackbuf |
protected static StringManager | sm
The string manager for this package. |
Constructor Summary | |
---|---|
BioSender() |
Method Summary | |
---|---|
protected void | closeSocket()
close socket
|
void | connect()
Connect other cluster member receiver |
void | disconnect()
disconnect and close socket
|
String | getInfo()
Return descriptive information about this implementation and the
corresponding version number, in the format
<description>/<version> . |
protected void | openSocket()
open real socket and set time out when waitForAck is enabled
is socket open return directly |
protected void | pushMessage(byte[] data, boolean reconnect, boolean waitForAck)
Push messages with only one socket at a time
Wait for ack is needed and make auto retry when write message is failed.
|
void | sendMessage(byte[] data, boolean waitForAck)
Send message
|
String | toString()
Name of this SockerSender |
protected void | waitForAck()
Wait for Acknowledgement from other server
FIXME Please, not wait only for three charcters, better control that the wait ack message is correct. |
See Also: disconnect DataSender
See Also: org.apache.catalina.tribes.transport.IDataSender#connect()
See Also: IDataSender#disconnect()
<description>/<version>
.Parameters: data data to send
Since: 5.5.10
See Also: closeSocket openSocket
See Also: org.apache.catalina.tribes.transport.IDataSender#sendMessage(, ChannelMessage)
Parameters: timeout
Throws: java.io.IOException java.net.SocketTimeoutException