com.ibasco.agql.protocols.valve.source.query

Class SourceQueryMessenger

java.lang.Object

com.ibasco.agql.core.NettyMessenger<SourceQueryRequest,SourceQueryResponse<?>>

com.ibasco.agql.protocols.valve.source.query.SourceQueryMessenger

All Implemented Interfaces:

Messenger<SourceQueryRequest,SourceQueryResponse<?>>, ConfigurationSupport, Closeable, AutoCloseable

@MessengerProperties(optionClass=SourceQueryOptions.class)
public final class SourceQueryMessenger
extends NettyMessenger<SourceQueryRequest,SourceQueryResponse<?>>

Messenger implementation for the Source Query Protocol

Author:

Rafael Luis Ibasco

Constructor Summary

Constructors

Constructor and Description
SourceQueryMessenger(Options options) Constructor for SourceQueryMessenger.

Method Summary

Modifier and Type	Method and Description
void	close()
protected void	configure(Options options) Populate configuration options.
protected NettyChannelFactory	createChannelFactory() createChannelFactory.
CompletableFuture<SourceQueryResponse<?>>	send(InetSocketAddress address, SourceQueryRequest request) Send request to the underlying Transport
protected Object	transformProperties(InetSocketAddress address, SourceQueryRequest request) transformProperties.

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

acquireContext, applyDefault, attach, createFactoryProvider, getChannelFactory, getExecutor, getFactoryProvider, getOptions, getTransport, lockedOption, receive, send

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

SourceQueryMessenger

public SourceQueryMessenger(Options options)

Constructor for SourceQueryMessenger.

Parameters:

options - a Options object

Method Detail

configure

protected void configure(Options options)

Populate configuration options. Subclasses should override this method. This is called right before the underlying transport is initialized.

Specified by:

configure in class NettyMessenger<SourceQueryRequest,SourceQueryResponse<?>>

Parameters:

options - The Options instance holding the configuration data

createChannelFactory

protected NettyChannelFactory createChannelFactory()

createChannelFactory.

Specified by:

createChannelFactory in class NettyMessenger<SourceQueryRequest,SourceQueryResponse<?>>

Returns:

a NettyChannelFactory object

send

public CompletableFuture<SourceQueryResponse<?>> send(InetSocketAddress address,
                                                      SourceQueryRequest request)

Send request to the underlying Transport

Specified by:

send in interface Messenger<SourceQueryRequest,SourceQueryResponse<?>>

Overrides:

send in class NettyMessenger<SourceQueryRequest,SourceQueryResponse<?>>

Parameters:

address - a InetSocketAddress object

request - a R object

Returns:

a CompletableFuture object

transformProperties

protected Object transformProperties(InetSocketAddress address,
                                     SourceQueryRequest request)

transformProperties.

Overrides:

transformProperties in class NettyMessenger<SourceQueryRequest,SourceQueryResponse<?>>

Parameters:

address - a InetSocketAddress object

request - a R object

Returns:

a Object object

close

public void close()
           throws IOException

Description copied from class: NettyMessenger

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Overrides:

close in class NettyMessenger<SourceQueryRequest,SourceQueryResponse<?>>

Throws:

IOException