com.ibasco.agql.core.transport

Class TcpNettyChannelFactory

java.lang.Object

com.ibasco.agql.core.transport.AbstractNettyChannelFactory

com.ibasco.agql.core.transport.TcpNettyChannelFactory

All Implemented Interfaces:

NettyChannelFactory, Closeable, AutoCloseable

public class TcpNettyChannelFactory
extends AbstractNettyChannelFactory

A netty based TCP Channel factory

Author:

Rafael Luis Ibasco

Constructor Summary

Constructors

Constructor and Description
TcpNettyChannelFactory(Options options) Constructor for TcpNettyChannelFactory.
TcpNettyChannelFactory(Options options, NettyPropertyResolver resolver) Constructor for TcpNettyChannelFactory.

Method Summary

Modifier and Type	Method and Description
protected void	configureBootstrap(io.netty.bootstrap.Bootstrap bootstrap) configureBootstrap.
protected CompletableFuture<io.netty.channel.Channel>	newChannel(Object data) newChannel.

Methods inherited from class com.ibasco.agql.core.transport.AbstractNettyChannelFactory

close, create, create, createRecvByteBufAllocator, getBootstrap, getChannelInitializer, getExecutor, getOptions, getResolver, getTransportType, initializeEventLoopGroup, setChannelInitializer, setResolver

Methods inherited from class java.lang.Object

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

Constructor Detail

TcpNettyChannelFactory

public TcpNettyChannelFactory(Options options)

Constructor for TcpNettyChannelFactory.

Parameters:

options - a Options object

TcpNettyChannelFactory

public TcpNettyChannelFactory(Options options,
                              NettyPropertyResolver resolver)

Constructor for TcpNettyChannelFactory.

Parameters:

options - a Options object

resolver - a NettyPropertyResolver object

Method Detail

newChannel

protected CompletableFuture<io.netty.channel.Channel> newChannel(Object data)

newChannel.

Specified by:

newChannel in class AbstractNettyChannelFactory

Parameters:

data - a Object object

Returns:

a CompletableFuture object

configureBootstrap

protected void configureBootstrap(io.netty.bootstrap.Bootstrap bootstrap)

configureBootstrap.

Overrides:

configureBootstrap in class AbstractNettyChannelFactory

Parameters:

bootstrap - a Bootstrap object