public class NioClient extends Object implements MessageWriteTarget
StreamParser to process data.| Constructor and Description |
|---|
NioClient(SocketAddress serverAddress,
StreamParser parser,
int connectTimeoutMillis)
Creates a new client to the given server address using the given
StreamParser to decode the data. |
| Modifier and Type | Method and Description |
|---|---|
void |
closeConnection()
Closes the connection to the server, triggering the
StreamParser.connectionClosed()
event on the network-handling thread where all callbacks occur. |
void |
writeBytes(byte[] message)
Writes the given bytes to the remote server.
|
public NioClient(SocketAddress serverAddress, StreamParser parser, int connectTimeoutMillis) throws IOException
Creates a new client to the given server address using the given StreamParser to decode the data.
The given parser MUST be unique to this object. This does not block while waiting for the connection to
open, but will call either the StreamParser.connectionOpened() or
StreamParser.connectionClosed() callback on the created network event processing thread.
connectTimeoutMillis - The connect timeout set on the connection (in milliseconds). 0 is interpreted as no
timeout.IOExceptionpublic void closeConnection()
MessageWriteTargetStreamParser.connectionClosed()
event on the network-handling thread where all callbacks occur.closeConnection in interface MessageWriteTargetpublic void writeBytes(byte[] message)
throws IOException
MessageWriteTargetwriteBytes in interface MessageWriteTargetIOExceptionCopyright © 2015. All rights reserved.