com.google.bitcoin.net

Class NioClient

java.lang.Object

com.google.bitcoin.net.NioClient

All Implemented Interfaces:

MessageWriteTarget

public class NioClient
extends Object
implements MessageWriteTarget

Creates a simple connection to a server using a StreamParser to process data.

Constructor Summary

Constructors

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.

Method Summary

Methods

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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

NioClient

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.

Parameters:

connectTimeoutMillis - The connect timeout set on the connection (in milliseconds). 0 is interpreted as no timeout.

Throws:

IOException

Method Detail

closeConnection

public void closeConnection()

Description copied from interface: MessageWriteTarget

Closes the connection to the server, triggering the StreamParser.connectionClosed() event on the network-handling thread where all callbacks occur.

Specified by:

closeConnection in interface MessageWriteTarget

writeBytes

public void writeBytes(byte[] message)
                throws IOException

Description copied from interface: MessageWriteTarget

Writes the given bytes to the remote server.

Specified by:

writeBytes in interface MessageWriteTarget

Throws:

IOException