com.ibasco.agql.core.transport

Class FailsafeChannelFactory

java.lang.Object

com.ibasco.agql.core.transport.NettyChannelFactoryDecorator

com.ibasco.agql.core.transport.FailsafeChannelFactory

All Implemented Interfaces:

NettyChannelFactory, Closeable, AutoCloseable

public class FailsafeChannelFactory
extends NettyChannelFactoryDecorator

Adds Failsafe support for the underlying NettyChannelFactory.

Author:

Rafael Luis Ibasco

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	FailsafeChannelFactory(NettyChannelFactory channelFactory) Constructor for FailsafeChannelFactory.

Method Summary

Modifier and Type	Method and Description
CompletableFuture<io.netty.channel.Channel>	create(Object data) create.
CompletableFuture<io.netty.channel.Channel>	create(Object data, io.netty.channel.EventLoop eventLoop) create.

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

close, getBootstrap, getChannelInitializer, getExecutor, getOptions, getResolver, getTransportType, setChannelInitializer, setResolver

Methods inherited from class java.lang.Object

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

Constructor Detail

FailsafeChannelFactory

protected FailsafeChannelFactory(NettyChannelFactory channelFactory)

Constructor for FailsafeChannelFactory.

Parameters:

channelFactory - a NettyChannelFactory object

Method Detail

create

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

create.

Specified by:

create in interface NettyChannelFactory

Overrides:

create in class NettyChannelFactoryDecorator

Parameters:

data - a Object object

Returns:

a CompletableFuture object

create

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

create.

Specified by:

create in interface NettyChannelFactory

Overrides:

create in class NettyChannelFactoryDecorator

Parameters:

data - a Object object

eventLoop - a EventLoop object

Returns:

a CompletableFuture object