com.ibasco.agql.core.transport.pool

Class PooledChannel

java.lang.Object

com.ibasco.agql.core.transport.pool.PooledChannel

All Implemented Interfaces:

io.netty.channel.Channel, io.netty.channel.ChannelOutboundInvoker, io.netty.util.AttributeMap, Comparable<io.netty.channel.Channel>

Direct Known Subclasses:

DefaultPooledChannel

public abstract class PooledChannel
extends Object
implements io.netty.channel.Channel

Abstract PooledChannel class.

Author:

Rafael Luis Ibasco

Nested Class Summary

Nested classes/interfaces inherited from interface io.netty.channel.Channel

io.netty.channel.Channel.Unsafe

Constructor Summary

Constructors

Constructor and Description
PooledChannel()

Method Summary

Modifier and Type	Method and Description
void	addListener(BiConsumer<PooledChannel,Throwable> listener) Add release listener
abstract NettyChannelPool	getChannelPool() getChannelPool.
abstract CompletableFuture<Void>	release() release.
void	removeListener(BiConsumer<PooledChannel,Throwable> listener) Remove release listener

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.netty.channel.Channel

alloc, bytesBeforeUnwritable, bytesBeforeWritable, closeFuture, config, eventLoop, flush, id, isActive, isOpen, isRegistered, isWritable, localAddress, metadata, parent, pipeline, read, remoteAddress, unsafe

Methods inherited from interface io.netty.util.AttributeMap

attr, hasAttr

Methods inherited from interface io.netty.channel.ChannelOutboundInvoker

bind, bind, close, close, connect, connect, connect, connect, deregister, deregister, disconnect, disconnect, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, voidPromise, write, write, writeAndFlush, writeAndFlush

Methods inherited from interface java.lang.Comparable

compareTo

Constructor Detail

PooledChannel

public PooledChannel()

Method Detail

addListener

public void addListener(BiConsumer<PooledChannel,Throwable> listener)

Add release listener

Parameters:

listener - The callback to notify when this channel has been released

removeListener

public void removeListener(BiConsumer<PooledChannel,Throwable> listener)

Remove release listener

Parameters:

listener - The callback to remove

getChannelPool

public abstract NettyChannelPool getChannelPool()

getChannelPool.

Returns:

a NettyChannelPool object

release

public abstract CompletableFuture<Void> release()

release.

Returns:

a CompletableFuture object