public class ClientTCPConnection extends ClientConnection
ClientConnection.AcceptCallback, ClientConnection.MessageCallback
aggregatedReceives, aggregatedSends, connectionTypeRDP, connectionTypeTCP, connectionTypeUDP, lock, logMessageContents, packetAggregator, receivedMessagesAggregated, sentMessagesAggregated, unaggregatedReceives, unaggregatedSends
Constructor and Description |
---|
ClientTCPConnection(ClientTCPMessageIO clientTCPMessageIO) |
ClientTCPConnection(ClientTCPMessageIO clientTCPMessageIO,
java.nio.channels.SocketChannel socketChannel,
ClientConnection.MessageCallback messageCallback) |
ClientTCPConnection(java.nio.channels.SocketChannel socketChannel) |
Modifier and Type | Method and Description |
---|---|
boolean |
canSend() |
boolean |
canSendInternal() |
void |
close() |
int |
connectionKind() |
void |
connectionReset() |
AgentInfo |
getAgentInfo() |
ClientConnection.MessageCallback |
getMessageCallback() |
protected void |
initializeFromSocketChannel(java.nio.channels.SocketChannel socketChannel) |
java.lang.String |
IPAndPort() |
boolean |
isOpen() |
void |
open(java.lang.String hostname,
int remotePort) |
void |
registerMessageCallback(ClientConnection.MessageCallback messageCallback) |
void |
send(AOByteBuffer buf) |
boolean |
sendIfPossible(AOByteBuffer buf) |
boolean |
sendInternal(AOByteBuffer buf) |
int |
sendMultibuf(java.util.List<AOByteBuffer> subMessages,
int currentSize) |
getAggregator, getAssociation, getLock, getLogMessageContents, setAssociation, setLogMessageContents, toString
public ClientTCPConnection(ClientTCPMessageIO clientTCPMessageIO)
public ClientTCPConnection(java.nio.channels.SocketChannel socketChannel)
public ClientTCPConnection(ClientTCPMessageIO clientTCPMessageIO, java.nio.channels.SocketChannel socketChannel, ClientConnection.MessageCallback messageCallback)
protected void initializeFromSocketChannel(java.nio.channels.SocketChannel socketChannel)
public java.lang.String IPAndPort()
IPAndPort
in class ClientConnection
public void registerMessageCallback(ClientConnection.MessageCallback messageCallback)
registerMessageCallback
in class ClientConnection
public ClientConnection.MessageCallback getMessageCallback()
public void send(AOByteBuffer buf)
send
in class ClientConnection
public boolean sendInternal(AOByteBuffer buf)
sendInternal
in class ClientConnection
public boolean sendIfPossible(AOByteBuffer buf)
sendIfPossible
in class ClientConnection
public int sendMultibuf(java.util.List<AOByteBuffer> subMessages, int currentSize)
sendMultibuf
in class ClientConnection
public void open(java.lang.String hostname, int remotePort)
open
in class ClientConnection
public void connectionReset()
connectionReset
in class ClientConnection
public void close()
close
in class ClientConnection
public boolean isOpen()
isOpen
in class ClientConnection
public boolean canSend()
canSend
in class ClientConnection
public boolean canSendInternal()
canSendInternal
in class ClientConnection
public int connectionKind()
connectionKind
in class ClientConnection
public AgentInfo getAgentInfo()