com.ibasco.agql.core

Class NettySocketClient<R extends AbstractRequest,S extends AbstractResponse>

java.lang.Object

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

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

Type Parameters:

R - A type of AbstractRequest

S - A type of AbstractResponse

All Implemented Interfaces:

Client, Closeable, AutoCloseable

Direct Known Subclasses:

MasterServerQueryClient, SourceQueryClient, SourceRconClient

public abstract class NettySocketClient<R extends AbstractRequest,S extends AbstractResponse>
extends AbstractClient<R,S>

A netty based socket client.

Author:

Rafael Luis Ibasco

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	close()
protected abstract NettyMessenger<R,S>	createMessenger(Options options) Factory method for Messenger.
boolean	equals(Object o)
ScheduledExecutorService	getExecutor() The underlying Executor used by this instance
protected NettyMessenger<R,S>	getMessenger() Getter for the field messenger.
int	hashCode()

Methods inherited from class com.ibasco.agql.core.AbstractClient

getOptions, id, send, send

Methods inherited from class java.lang.Object

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

Constructor Detail

NettySocketClient

protected NettySocketClient()

Create a new client instance using the default configuration options.

NettySocketClient

protected NettySocketClient(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

Method Detail

createMessenger

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

Factory method for Messenger.

Specified by:

createMessenger in class AbstractClient<R extends AbstractRequest,S extends AbstractResponse>

Parameters:

options - a Options object

Returns:

a Messenger object

getExecutor

public ScheduledExecutorService getExecutor()

The underlying Executor used by this instance

Specified by:

getExecutor in interface Client

Overrides:

getExecutor in class AbstractClient<R extends AbstractRequest,S extends AbstractResponse>

Returns:

The Executor object

getMessenger

protected NettyMessenger<R,S> getMessenger()

Getter for the field messenger.

Overrides:

getMessenger in class AbstractClient<R extends AbstractRequest,S extends AbstractResponse>

Returns:

a Messenger object

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Overrides:

close in class AbstractClient<R extends AbstractRequest,S extends AbstractResponse>

Throws:

IOException

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object o)

Overrides:

equals in class Object