public class TCPOutputConnection
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
protected TCPTransport.Cleaner |
cleaner
The cleaner.
|
protected java.net.Socket |
sock
The client socket for sending data.
|
protected java.io.OutputStream |
sos
The output stream.
|
static int |
TIMEOUT
5 sec timeout.
|
Constructor and Description |
---|
TCPOutputConnection(TCPTransport.Cleaner cleaner,
java.net.Socket sock)
Create a new tcp connection for sending data.
|
Modifier and Type | Method and Description |
---|---|
void |
close()
Close the connection.
|
boolean |
isClosed()
Test if the connection is closed.
|
boolean |
send(byte[] prolog,
byte[] data,
ISendTask task)
Send a message.
|
public static final int TIMEOUT
protected java.net.Socket sock
protected java.io.OutputStream sos
protected TCPTransport.Cleaner cleaner
public TCPOutputConnection(TCPTransport.Cleaner cleaner, java.net.Socket sock) throws java.io.IOException
java.io.IOException
public boolean send(byte[] prolog, byte[] data, ISendTask task)
msg
- The message.
(todo: relax synchronization by performing sends
on extra sender thread of transport)public boolean isClosed()
public void close()