com.ibasco.agql.core.transport

Class AbstractNettyChannelFactory

java.lang.Object

com.ibasco.agql.core.transport.AbstractNettyChannelFactory

All Implemented Interfaces:

NettyChannelFactory, Closeable, AutoCloseable

Direct Known Subclasses:

TcpNettyChannelFactory, UdpNettyChannelFactory

public abstract class AbstractNettyChannelFactory
extends Object
implements NettyChannelFactory

Base class for all Channel factories utilitizing netty's Bootstrap

Author:

Rafael Luis Ibasco

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractNettyChannelFactory(TransportType type, Options options, NettyPropertyResolver resolver) Constructor for AbstractNettyChannelFactory.
protected	AbstractNettyChannelFactory(TransportType type, Options options, NettyPropertyResolver resolver, NettyChannelInitializer initializer) Constructor for AbstractNettyChannelFactory.

Method Summary

Modifier and Type	Method and Description
void	close()
protected void	configureBootstrap(io.netty.bootstrap.Bootstrap bootstrap) configureBootstrap.
CompletableFuture<io.netty.channel.Channel>	create(Object data) create.
CompletableFuture<io.netty.channel.Channel>	create(Object data, io.netty.channel.EventLoop eventLoop) create.
protected io.netty.channel.RecvByteBufAllocator	createRecvByteBufAllocator() createRecvByteBufAllocator.
io.netty.bootstrap.Bootstrap	getBootstrap() getBootstrap.
NettyChannelInitializer	getChannelInitializer() getChannelInitializer.
io.netty.channel.EventLoopGroup	getExecutor() getExecutor.
Options	getOptions() getOptions.
NettyPropertyResolver	getResolver() getResolver.
TransportType	getTransportType() getTransportType.
protected io.netty.channel.EventLoopGroup	initializeEventLoopGroup(@NotNull Class<? extends io.netty.channel.Channel> channelClass, @NotNull ExecutorService executorService) Initialize EventLoopGroup.
protected abstract CompletableFuture<io.netty.channel.Channel>	newChannel(Object data) newChannel.
void	setChannelInitializer(NettyChannelInitializer channelInitializer) setChannelInitializer.
void	setResolver(NettyPropertyResolver resolver) setResolver.

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractNettyChannelFactory

protected AbstractNettyChannelFactory(TransportType type,
                                      Options options,
                                      NettyPropertyResolver resolver)

Constructor for AbstractNettyChannelFactory.

Parameters:

type - a TransportType object

options - a Options object

resolver - a NettyPropertyResolver object

AbstractNettyChannelFactory

protected AbstractNettyChannelFactory(TransportType type,
                                      Options options,
                                      NettyPropertyResolver resolver,
                                      NettyChannelInitializer initializer)

Constructor for AbstractNettyChannelFactory.

Parameters:

type - a TransportType object

options - a Options object

resolver - a NettyPropertyResolver object

initializer - a NettyChannelInitializer object

Method Detail

initializeEventLoopGroup

protected io.netty.channel.EventLoopGroup initializeEventLoopGroup(@NotNull
                                                                   @NotNull Class<? extends io.netty.channel.Channel> channelClass,
                                                                   @NotNull
                                                                   @NotNull ExecutorService executorService)

Initialize EventLoopGroup.

Parameters:

channelClass - a Class object

executorService - a ExecutorService object

Returns:

a EventLoopGroup object

newChannel

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

newChannel.

Parameters:

data - a Object object

Returns:

a CompletableFuture object

create

public final CompletableFuture<io.netty.channel.Channel> create(Object data)

create.

Specified by:

create in interface NettyChannelFactory

Parameters:

data - a Object object

Returns:

a CompletableFuture object

configureBootstrap

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

configureBootstrap.

Parameters:

bootstrap - a Bootstrap object

create

public final CompletableFuture<io.netty.channel.Channel> create(Object data,
                                                                io.netty.channel.EventLoop eventLoop)

create.

Specified by:

create in interface NettyChannelFactory

Parameters:

data - a Object object

eventLoop - a EventLoop object

Returns:

a CompletableFuture object

createRecvByteBufAllocator

protected io.netty.channel.RecvByteBufAllocator createRecvByteBufAllocator()

createRecvByteBufAllocator.

Returns:

a RecvByteBufAllocator object

getTransportType

public TransportType getTransportType()

getTransportType.

Specified by:

getTransportType in interface NettyChannelFactory

Returns:

a TransportType object

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

getChannelInitializer

public NettyChannelInitializer getChannelInitializer()

getChannelInitializer.

Specified by:

getChannelInitializer in interface NettyChannelFactory

Returns:

a NettyChannelInitializer object

setChannelInitializer

public void setChannelInitializer(NettyChannelInitializer channelInitializer)

setChannelInitializer.

Specified by:

setChannelInitializer in interface NettyChannelFactory

Parameters:

channelInitializer - a NettyChannelInitializer object

getResolver

public NettyPropertyResolver getResolver()

getResolver.

Specified by:

getResolver in interface NettyChannelFactory

Returns:

a NettyPropertyResolver object

setResolver

public void setResolver(NettyPropertyResolver resolver)

setResolver.

Specified by:

setResolver in interface NettyChannelFactory

Parameters:

resolver - a NettyPropertyResolver object

getExecutor

public io.netty.channel.EventLoopGroup getExecutor()

getExecutor.

Specified by:

getExecutor in interface NettyChannelFactory

Returns:

a EventLoopGroup object

getBootstrap

public io.netty.bootstrap.Bootstrap getBootstrap()

getBootstrap.

Specified by:

getBootstrap in interface NettyChannelFactory

Returns:

a Bootstrap object

getOptions

public Options getOptions()

getOptions.

Specified by:

getOptions in interface NettyChannelFactory

Returns:

a Options object