com.ibasco.agql.core

Class NettyTransport

java.lang.Object

com.ibasco.agql.core.NettyTransport

All Implemented Interfaces:

Transport<NettyChannelContext,NettyChannelContext>, ConfigurationSupport, Closeable, AutoCloseable

public class NettyTransport
extends Object
implements Transport<NettyChannelContext,NettyChannelContext>

The netty transport driver, responsible for sending the messages to the provided Channel.

Author:

Rafael Luis Ibasco

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	close()
Options	getOptions() getOptions.
CompletableFuture<NettyChannelContext>	send(NettyChannelContext context) 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

NettyTransport

public NettyTransport(Options options)

Constructor for NettyTransport.

Parameters:

options - a Options object

Method Detail

send

public final CompletableFuture<NettyChannelContext> send(NettyChannelContext context)

send.

Specified by:

send in interface Transport<NettyChannelContext,NettyChannelContext>

Parameters:

context - a R object

Returns:

a CompletableFuture object

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

getOptions

public final Options getOptions()

getOptions.

Specified by:

getOptions in interface ConfigurationSupport

Returns:

a Options object