com.ibasco.agql.core

Interface Messenger<R extends AbstractRequest,S extends AbstractResponse>

All Superinterfaces:

AutoCloseable, Closeable, ConfigurationSupport

All Known Implementing Classes:

HttpMessenger, MasterServerMessenger, NettyMessenger, SourceQueryMessenger, SourceRconMessenger

public interface Messenger<R extends AbstractRequest,S extends AbstractResponse>
extends Closeable, ConfigurationSupport

The following are characteristics/roles of a Messenger

• Responsible for creating, acquiring, closing or releasing a network resource (e.g. Channel/Connection)
• Prepares and initialize the request for Transport
• Receives a response from the remote server, performs additional processing (if needed) and routes the response back to the Client
• Has a 1 to 1 relationship with the Client

Author:

Rafael Luis Ibasco

Method Summary

Modifier and Type	Method and Description
Executor	getExecutor() The Executor utilized by this messenger
Transport<?,?>	getTransport() The underlying Transport used by this instance
CompletableFuture<S>	send(InetSocketAddress address, R request) Send request to the underlying Transport

Methods inherited from interface java.io.Closeable

close

Methods inherited from interface com.ibasco.agql.core.util.ConfigurationSupport

get, get, getOptions, getOrDefault, getOrDefault, lock, set, unlock

Method Detail

send

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

Send request to the underlying Transport

Parameters:

address - a InetSocketAddress object

request - a R object

Returns:

a CompletableFuture object

getTransport

Transport<?,?> getTransport()

The underlying Transport used by this instance

Returns:

a Transport object

getExecutor

Executor getExecutor()

The Executor utilized by this messenger

Returns:

a Executor object