com.ibasco.agql.core

Class HttpMessenger

java.lang.Object

com.ibasco.agql.core.HttpMessenger

All Implemented Interfaces:

Messenger<AbstractWebRequest,AbstractWebResponse>, ConfigurationSupport, Closeable, AutoCloseable

public final class HttpMessenger
extends Object
implements Messenger<AbstractWebRequest,AbstractWebResponse>

A Messenger responsible for handling Web Requests and Responses.

Author:

Rafael Luis Ibasco

Constructor Summary

Constructors

Constructor and Description
HttpMessenger(Function<org.asynchttpclient.Response,AbstractWebResponse> responseFactory, HttpOptions options) Constructor for HttpMessenger.

Method Summary

Modifier and Type	Method and Description
void	close()
io.netty.channel.EventLoopGroup	getExecutor() The Executor utilized by this messenger
HttpOptions	getOptions() getOptions.
AsyncHttpTransport	getTransport() The underlying Transport used by this instance
CompletableFuture<AbstractWebResponse>	send(InetSocketAddress address, AbstractWebRequest request) Send request to the underlying Transport

Methods inherited from class java.lang.Object

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

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

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

Constructor Detail

HttpMessenger

public HttpMessenger(Function<org.asynchttpclient.Response,AbstractWebResponse> responseFactory,
                     HttpOptions options)

Constructor for HttpMessenger.

Parameters:

responseFactory - a Function object

options - a Options object

Method Detail

getOptions

public HttpOptions getOptions()

getOptions.

Specified by:

getOptions in interface ConfigurationSupport

Returns:

a Options object

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

send

public CompletableFuture<AbstractWebResponse> send(InetSocketAddress address,
                                                   AbstractWebRequest request)

Send request to the underlying Transport

Specified by:

send in interface Messenger<AbstractWebRequest,AbstractWebResponse>

Parameters:

address - a InetSocketAddress object

request - a R object

Returns:

a CompletableFuture object

getTransport

public AsyncHttpTransport getTransport()

The underlying Transport used by this instance

Specified by:

getTransport in interface Messenger<AbstractWebRequest,AbstractWebResponse>

Returns:

a Transport object

getExecutor

public io.netty.channel.EventLoopGroup getExecutor()

The Executor utilized by this messenger

Specified by:

getExecutor in interface Messenger<AbstractWebRequest,AbstractWebResponse>

Returns:

a Executor object