com.ibasco.agql.core

Class AbstractClient<R extends AbstractRequest,S extends AbstractResponse>

java.lang.Object

com.ibasco.agql.core.AbstractClient<R,S>

Type Parameters:

R - A type of AbstractRequest

S - A type of AbstractResponse

All Implemented Interfaces:

Client, Closeable, AutoCloseable

Direct Known Subclasses:

AbstractRestClient, NettySocketClient

public abstract class AbstractClient<R extends AbstractRequest,S extends AbstractResponse>
extends Object
implements Client

Base implementation for all Client interfaces.

Author:

Rafael Luis Ibasco.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractClient(Options options) Create a new client instance using the provided configuration options.

Method Summary

Modifier and Type	Method and Description
void	close()
protected abstract Messenger<R,S>	createMessenger(Options options) Factory method for Messenger.
Executor	getExecutor() The underlying Executor used by this instance
protected Messenger<R,S>	getMessenger() Getter for the field messenger.
Options	getOptions()
UUID	id() The unique-id of this instance
protected CompletableFuture<S>	send(InetSocketAddress address, R request) Send request to messenger.
protected <V extends S> CompletableFuture<V>	send(InetSocketAddress address, R request, Class<V> expectedResponse) Send request.

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractClient

protected AbstractClient(Options options)

Create a new client instance using the provided configuration options.

Parameters:

options - The Options containing the configuration options that will be used by the client

See Also:

OptionBuilder, Options

Method Detail

send

protected <V extends S> CompletableFuture<V> send(InetSocketAddress address,
                                                  R request,
                                                  Class<V> expectedResponse)

Send request.

Type Parameters:

V - a V class

Parameters:

address - a InetSocketAddress object

request - a R object

expectedResponse - a Class object

Returns:

a CompletableFuture object

send

protected final CompletableFuture<S> send(InetSocketAddress address,
                                          R request)

Send request to messenger.

Parameters:

address - The InetSocketAddress destination

request - The AbstractRequest to be sent

Returns:

A CompletableFuture that is notified once a response has been received.

createMessenger

protected abstract Messenger<R,S> createMessenger(Options options)

Factory method for Messenger.

Parameters:

options - a Options object

Returns:

a Messenger object

id

public UUID id()

The unique-id of this instance

Specified by:

id in interface Client

Returns:

A UUID object

getExecutor

public Executor getExecutor()

The underlying Executor used by this instance

Specified by:

getExecutor in interface Client

Returns:

The Executor object

getMessenger

protected Messenger<R,S> getMessenger()

Getter for the field messenger.

Returns:

a Messenger object

getOptions

public final Options getOptions()

Returns:

The configuration Options used by this instance

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException