com.ibasco.agql.core.transport.pool

Class DefaultPooledChannel

java.lang.Object

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

com.ibasco.agql.core.transport.pool.DefaultPooledChannel

All Implemented Interfaces:

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

public class DefaultPooledChannel
extends PooledChannel

A class that wraps an existing netty based Channel representing a channel that has been acquired from a NettyChannelPool.

Note that using ChannelFuture.channel() does not return the actual PooledChannel type but the underlying Channel instance. This can be a problem when accessing a PooledChannel instance from a Collection

Author:

Rafael Luis Ibasco

Nested Class Summary

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

io.netty.channel.Channel.Unsafe

Method Summary

Modifier and Type	Method and Description
io.netty.buffer.ByteBufAllocator	alloc()
<T> io.netty.util.Attribute<T>	attr(io.netty.util.AttributeKey<T> key)
io.netty.channel.ChannelFuture	bind(SocketAddress localAddress)
io.netty.channel.ChannelFuture	bind(SocketAddress localAddress, io.netty.channel.ChannelPromise promise)
long	bytesBeforeUnwritable()
long	bytesBeforeWritable()
io.netty.channel.ChannelFuture	close()
io.netty.channel.ChannelFuture	close(io.netty.channel.ChannelPromise promise)
io.netty.channel.ChannelFuture	closeFuture()
int	compareTo(@NotNull io.netty.channel.Channel o)
io.netty.channel.ChannelConfig	config()
io.netty.channel.ChannelFuture	connect(SocketAddress remoteAddress)
io.netty.channel.ChannelFuture	connect(SocketAddress remoteAddress, io.netty.channel.ChannelPromise promise)
io.netty.channel.ChannelFuture	connect(SocketAddress remoteAddress, SocketAddress localAddress)
io.netty.channel.ChannelFuture	connect(SocketAddress remoteAddress, SocketAddress localAddress, io.netty.channel.ChannelPromise promise)
io.netty.channel.ChannelFuture	deregister()
io.netty.channel.ChannelFuture	deregister(io.netty.channel.ChannelPromise promise)
io.netty.channel.ChannelFuture	disconnect()
io.netty.channel.ChannelFuture	disconnect(io.netty.channel.ChannelPromise promise)
boolean	equals(Object obj)
io.netty.channel.EventLoop	eventLoop()
io.netty.channel.Channel	flush()
NettyChannelPool	getChannelPool() getChannelPool.
<T> boolean	hasAttr(io.netty.util.AttributeKey<T> key)
int	hashCode()
io.netty.channel.ChannelId	id()
boolean	isActive()
boolean	isOpen()
boolean	isRegistered()
boolean	isWritable()
SocketAddress	localAddress()
io.netty.channel.ChannelMetadata	metadata()
io.netty.channel.ChannelFuture	newFailedFuture(Throwable cause)
io.netty.channel.ChannelProgressivePromise	newProgressivePromise()
io.netty.channel.ChannelPromise	newPromise()
io.netty.channel.ChannelFuture	newSucceededFuture()
io.netty.channel.Channel	parent()
io.netty.channel.ChannelPipeline	pipeline()
io.netty.channel.Channel	read()
CompletableFuture<Void>	release() release.
SocketAddress	remoteAddress()
String	toString()
io.netty.channel.Channel.Unsafe	unsafe()
io.netty.channel.ChannelPromise	voidPromise()
io.netty.channel.ChannelFuture	write(Object msg)
io.netty.channel.ChannelFuture	write(Object msg, io.netty.channel.ChannelPromise promise)
io.netty.channel.ChannelFuture	writeAndFlush(Object msg)
io.netty.channel.ChannelFuture	writeAndFlush(Object msg, io.netty.channel.ChannelPromise promise)

Methods inherited from class com.ibasco.agql.core.transport.pool.PooledChannel

addListener, removeListener

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Method Detail

id

public io.netty.channel.ChannelId id()

eventLoop

public io.netty.channel.EventLoop eventLoop()

parent

public io.netty.channel.Channel parent()

config

public io.netty.channel.ChannelConfig config()

isOpen

public boolean isOpen()

isRegistered

public boolean isRegistered()

isActive

public boolean isActive()

metadata

public io.netty.channel.ChannelMetadata metadata()

localAddress

public SocketAddress localAddress()

remoteAddress

public SocketAddress remoteAddress()

closeFuture

public io.netty.channel.ChannelFuture closeFuture()

isWritable

public boolean isWritable()

bytesBeforeUnwritable

public long bytesBeforeUnwritable()

bytesBeforeWritable

public long bytesBeforeWritable()

unsafe

public io.netty.channel.Channel.Unsafe unsafe()

pipeline

public io.netty.channel.ChannelPipeline pipeline()

alloc

public io.netty.buffer.ByteBufAllocator alloc()

read

public io.netty.channel.Channel read()

flush

public io.netty.channel.Channel flush()

bind

public io.netty.channel.ChannelFuture bind(SocketAddress localAddress)

attr

public <T> io.netty.util.Attribute<T> attr(io.netty.util.AttributeKey<T> key)

connect

public io.netty.channel.ChannelFuture connect(SocketAddress remoteAddress)

hasAttr

public <T> boolean hasAttr(io.netty.util.AttributeKey<T> key)

connect

public io.netty.channel.ChannelFuture connect(SocketAddress remoteAddress,
                                              SocketAddress localAddress)

disconnect

public io.netty.channel.ChannelFuture disconnect()

close

public io.netty.channel.ChannelFuture close()

deregister

public io.netty.channel.ChannelFuture deregister()

bind

public io.netty.channel.ChannelFuture bind(SocketAddress localAddress,
                                           io.netty.channel.ChannelPromise promise)

connect

public io.netty.channel.ChannelFuture connect(SocketAddress remoteAddress,
                                              io.netty.channel.ChannelPromise promise)

connect

public io.netty.channel.ChannelFuture connect(SocketAddress remoteAddress,
                                              SocketAddress localAddress,
                                              io.netty.channel.ChannelPromise promise)

disconnect

public io.netty.channel.ChannelFuture disconnect(io.netty.channel.ChannelPromise promise)

close

public io.netty.channel.ChannelFuture close(io.netty.channel.ChannelPromise promise)

deregister

public io.netty.channel.ChannelFuture deregister(io.netty.channel.ChannelPromise promise)

write

public io.netty.channel.ChannelFuture write(Object msg)

write

public io.netty.channel.ChannelFuture write(Object msg,
                                            io.netty.channel.ChannelPromise promise)

writeAndFlush

public io.netty.channel.ChannelFuture writeAndFlush(Object msg,
                                                    io.netty.channel.ChannelPromise promise)

writeAndFlush

public io.netty.channel.ChannelFuture writeAndFlush(Object msg)

newPromise

public io.netty.channel.ChannelPromise newPromise()

newProgressivePromise

public io.netty.channel.ChannelProgressivePromise newProgressivePromise()

newSucceededFuture

public io.netty.channel.ChannelFuture newSucceededFuture()

newFailedFuture

public io.netty.channel.ChannelFuture newFailedFuture(Throwable cause)

voidPromise

public io.netty.channel.ChannelPromise voidPromise()

compareTo

public int compareTo(@NotNull
                     @NotNull io.netty.channel.Channel o)

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

toString

public String toString()

Overrides:

toString in class Object

getChannelPool

public NettyChannelPool getChannelPool()

getChannelPool.

Specified by:

getChannelPool in class PooledChannel

Returns:

a NettyChannelPool object

release

public CompletableFuture<Void> release()

release.

Specified by:

release in class PooledChannel

Returns:

a CompletableFuture object