Uses of Interface
io.netty.channel.Channel
-
Packages that use Channel Package Description io.netty.bootstrap The helper classes with fluent API which enable an easy implementation of typical client side and server side channel initialization.io.netty.channel The core channel API which is asynchronous and event-driven abstraction of various transports such as a NIO Channel.io.netty.channel.embedded A virtualChannel
that helps wrapping a series of handlers to unit test the handlers or use them in non-I/O context.io.netty.channel.epoll Optimized transport for linux which uses EPOLL Edge-Triggered Mode for maximal performance.io.netty.channel.group A channel registry which helps a user maintain the list of openChannel
s and perform bulk operations on them.io.netty.channel.kqueue BSD specific transport.io.netty.channel.local A virtual transport that enables the communication between the two parties in the same virtual machine.io.netty.channel.nio NIO-based channel API implementation - recommended for a large number of connections (>= 1000).io.netty.channel.oio Old blocking I/O based channel API implementation - recommended for a small number of connections (< 1000).io.netty.channel.pool Implementations and API forChannel
pools.io.netty.channel.sctp Abstract SCTP socket interfaces which extend the core channel API.io.netty.channel.sctp.nio NIO-based SCTP Channel API implementation - recommended for a large number of connections (>= 1000).io.netty.channel.sctp.oio Old blocking I/O based SCTP channel API implementation - recommended for a small number of connections (< 1000).io.netty.channel.socket Abstract TCP and UDP socket interfaces which extend the core channel API.io.netty.channel.socket.nio NIO-based socket channel API implementation - recommended for a large number of connections (>= 1000).io.netty.channel.socket.oio Old blocking I/O based socket channel API implementation - recommended for a small number of connections (< 1000).io.netty.channel.unix Unix specific transport.io.netty.handler.codec.http.websocketx Encoder, decoder, handshakers and their related message types for Web Socket data frames.io.netty.handler.codec.http2 Handlers for sending and receiving HTTP/2 frames.io.netty.handler.pcap Capture data and write into Pcap format which helps in troubleshooting.io.netty.handler.proxy Adds support for client connections via proxy protocols such as SOCKS and HTTP CONNECT tunnelingio.netty.handler.ssl SSL · TLS implementation based onSSLEngine
io.netty.resolver.dns An alternative to Java's built-in domain name lookup mechanism that resolves a domain name asynchronously, which supports the queries of an arbitrary DNS record type as well. -
-
Uses of Channel in io.netty.bootstrap
Classes in io.netty.bootstrap with type parameters of type Channel Modifier and Type Class Description class
AbstractBootstrap<B extends AbstractBootstrap<B,C>,C extends Channel>
AbstractBootstrap
is a helper class that makes it easy to bootstrap aChannel
.class
AbstractBootstrapConfig<B extends AbstractBootstrap<B,C>,C extends Channel>
Exposes the configuration of anAbstractBootstrap
.interface
ChannelFactory<T extends Channel>
Deprecated.UseChannelFactory
instead.Classes in io.netty.bootstrap that implement Channel Modifier and Type Class Description (package private) class
FailedChannel
Methods in io.netty.bootstrap with parameters of type Channel Modifier and Type Method Description private static void
AbstractBootstrap. doBind0(ChannelFuture regFuture, Channel channel, java.net.SocketAddress localAddress, ChannelPromise promise)
private ChannelFuture
Bootstrap. doResolveAndConnect0(Channel channel, java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)
private static void
ServerBootstrap.ServerBootstrapAcceptor. forceClose(Channel child, java.lang.Throwable t)
(package private) abstract void
AbstractBootstrap. init(Channel channel)
(package private) void
Bootstrap. init(Channel channel)
(package private) void
ServerBootstrap. init(Channel channel)
void
ChannelInitializerExtension. postInitializeClientChannel(Channel channel)
Called byBootstrap
after the initialization of the given client channel.void
ChannelInitializerExtension. postInitializeServerChildChannel(Channel channel)
Called byServerBootstrap
after the initialization of the given child channel.(package private) static void
AbstractBootstrap. setAttributes(Channel channel, java.util.Map.Entry<AttributeKey<?>,java.lang.Object>[] attrs)
private static void
AbstractBootstrap. setChannelOption(Channel channel, ChannelOption<?> option, java.lang.Object value, InternalLogger logger)
(package private) static void
AbstractBootstrap. setChannelOptions(Channel channel, java.util.Map.Entry<ChannelOption<?>,java.lang.Object>[] options, InternalLogger logger)
Constructors in io.netty.bootstrap with parameters of type Channel Constructor Description PendingRegistrationPromise(Channel channel)
ServerBootstrapAcceptor(Channel channel, EventLoopGroup childGroup, ChannelHandler childHandler, java.util.Map.Entry<ChannelOption<?>,java.lang.Object>[] childOptions, java.util.Map.Entry<AttributeKey<?>,java.lang.Object>[] childAttrs, java.util.Collection<ChannelInitializerExtension> extensions)
-
Uses of Channel in io.netty.channel
Classes in io.netty.channel with type parameters of type Channel Modifier and Type Interface Description interface
ChannelFactory<T extends Channel>
Creates a newChannel
.class
ChannelInitializer<C extends Channel>
A specialChannelInboundHandler
which offers an easy way to initialize aChannel
once it was registered to itsEventLoop
.class
ReflectiveChannelFactory<T extends Channel>
AChannelFactory
that instantiates a newChannel
by invoking its default constructor reflectively.protected static class
SingleThreadEventLoop.ChannelsReadOnlyIterator<T extends Channel>
Subinterfaces of Channel in io.netty.channel Modifier and Type Interface Description interface
ServerChannel
Classes in io.netty.channel that implement Channel Modifier and Type Class Description class
AbstractChannel
A skeletalChannel
implementation.class
AbstractServerChannel
A skeletal server-sideChannel
implementation.Fields in io.netty.channel declared as Channel Modifier and Type Field Description private Channel
ThreadPerChannelEventLoop. ch
Deprecated.private Channel
ChannelOutboundBuffer. channel
private Channel
CoalescingBufferQueue. channel
private Channel
CompleteChannelFuture. channel
protected Channel
DefaultChannelConfig. channel
private Channel
DefaultChannelPipeline. channel
private Channel
DefaultChannelProgressivePromise. channel
private Channel
DefaultChannelPromise. channel
private Channel
VoidChannelPromise. channel
private Channel
AbstractChannel. parent
Methods in io.netty.channel that return Channel Modifier and Type Method Description Channel
AbstractChannelHandlerContext. channel()
Channel
ChannelFuture. channel()
Returns a channel where the I/O operation associated with this future takes place.Channel
ChannelHandlerContext. channel()
Return theChannel
which is bound to theChannelHandlerContext
.Channel
ChannelPipeline. channel()
Returns theChannel
that this pipeline is attached to.Channel
ChannelPromise. channel()
Channel
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext. channel()
Channel
CompleteChannelFuture. channel()
Channel
DefaultChannelPipeline. channel()
Channel
DefaultChannelProgressivePromise. channel()
Channel
DefaultChannelPromise. channel()
Channel
DelegatingChannelPromiseNotifier. channel()
Channel
VoidChannelPromise. channel()
Channel
AbstractChannel. flush()
Channel
Channel. flush()
Channel
SingleThreadEventLoop.ChannelsReadOnlyIterator. next()
Channel
AbstractChannel. parent()
Channel
Channel. parent()
Returns the parent of this channel.Channel
AbstractChannel. read()
Channel
Channel. read()
Methods in io.netty.channel that return types with arguments of type Channel Modifier and Type Method Description java.util.Iterator<Channel>
SingleThreadEventLoop. registeredChannelsIterator()
Methods in io.netty.channel with parameters of type Channel Modifier and Type Method Description int
AbstractChannel. compareTo(Channel o)
(package private) static PendingBytesTracker
PendingBytesTracker. newTracker(Channel channel)
ChannelFuture
EventLoopGroup. register(Channel channel)
ChannelFuture
EventLoopGroup. register(Channel channel, ChannelPromise promise)
Deprecated.UseEventLoopGroup.register(ChannelPromise)
instead.ChannelFuture
MultithreadEventLoopGroup. register(Channel channel)
ChannelFuture
MultithreadEventLoopGroup. register(Channel channel, ChannelPromise promise)
Deprecated.ChannelFuture
SingleThreadEventLoop. register(Channel channel)
ChannelFuture
SingleThreadEventLoop. register(Channel channel, ChannelPromise promise)
Deprecated.ChannelFuture
ThreadPerChannelEventLoop. register(Channel channel, ChannelPromise promise)
Deprecated.ChannelFuture
ThreadPerChannelEventLoopGroup. register(Channel channel)
Deprecated.ChannelFuture
ThreadPerChannelEventLoopGroup. register(Channel channel, ChannelPromise promise)
Deprecated.Constructors in io.netty.channel with parameters of type Channel Constructor Description AbstractChannel(Channel parent)
Creates a new instance.AbstractChannel(Channel parent, ChannelId id)
Creates a new instance.AbstractCoalescingBufferQueue(Channel channel, int initSize)
Create a new instance.CoalescingBufferQueue(Channel channel)
CoalescingBufferQueue(Channel channel, int initSize)
CoalescingBufferQueue(Channel channel, int initSize, boolean updateWritability)
CompleteChannelFuture(Channel channel, EventExecutor executor)
Creates a new instance.DefaultChannelConfig(Channel channel)
DefaultChannelConfig(Channel channel, RecvByteBufAllocator allocator)
DefaultChannelPipeline(Channel channel)
DefaultChannelProgressivePromise(Channel channel)
Creates a new instance.DefaultChannelProgressivePromise(Channel channel, EventExecutor executor)
Creates a new instance.DefaultChannelPromise(Channel channel)
Creates a new instance.DefaultChannelPromise(Channel channel, EventExecutor executor)
Creates a new instance.FailedChannelFuture(Channel channel, EventExecutor executor, java.lang.Throwable cause)
Creates a new instance.PendingWriteQueue(Channel channel)
SucceededChannelFuture(Channel channel, EventExecutor executor)
Creates a new instance.VoidChannelPromise(Channel channel, boolean fireException)
Creates a new instance. -
Uses of Channel in io.netty.channel.embedded
Classes in io.netty.channel.embedded that implement Channel Modifier and Type Class Description class
EmbeddedChannel
Base class forChannel
implementations that are used in an embedded fashion.Methods in io.netty.channel.embedded that return Channel Modifier and Type Method Description Channel
EmbeddedChannel. flush()
Channel
EmbeddedChannel. read()
Methods in io.netty.channel.embedded with parameters of type Channel Modifier and Type Method Description ChannelFuture
EmbeddedEventLoop. register(Channel channel)
ChannelFuture
EmbeddedEventLoop. register(Channel channel, ChannelPromise promise)
Deprecated.Constructors in io.netty.channel.embedded with parameters of type Channel Constructor Description EmbeddedChannel(Channel parent, ChannelId channelId, boolean register, boolean hasDisconnect, ChannelHandler... handlers)
Create a new instance with the channel ID set to the given ID and the pipeline initialized with the specified handlers. -
Uses of Channel in io.netty.channel.epoll
Classes in io.netty.channel.epoll that implement Channel Modifier and Type Class Description (package private) class
AbstractEpollChannel
class
AbstractEpollServerChannel
class
AbstractEpollStreamChannel
class
EpollDatagramChannel
DatagramChannel
implementation that uses linux EPOLL Edge-Triggered Mode for maximal performance.class
EpollDomainDatagramChannel
class
EpollDomainSocketChannel
class
EpollServerDomainSocketChannel
class
EpollServerSocketChannel
ServerSocketChannel
implementation that uses linux EPOLL Edge-Triggered Mode for maximal performance.class
EpollSocketChannel
SocketChannel
implementation that uses linux EPOLL Edge-Triggered Mode for maximal performance.Methods in io.netty.channel.epoll that return Channel Modifier and Type Method Description private static Channel
EpollChannelConfig. checkAbstractEpollChannel(Channel channel)
protected abstract Channel
AbstractEpollServerChannel. newChildChannel(int fd, byte[] remote, int offset, int len)
protected Channel
EpollServerDomainSocketChannel. newChildChannel(int fd, byte[] addr, int offset, int len)
protected Channel
EpollServerSocketChannel. newChildChannel(int fd, byte[] address, int offset, int len)
Methods in io.netty.channel.epoll that return types with arguments of type Channel Modifier and Type Method Description java.util.Iterator<Channel>
EpollEventLoop. registeredChannelsIterator()
Methods in io.netty.channel.epoll with parameters of type Channel Modifier and Type Method Description private static Channel
EpollChannelConfig. checkAbstractEpollChannel(Channel channel)
Constructors in io.netty.channel.epoll with parameters of type Channel Constructor Description AbstractEpollChannel(Channel parent, LinuxSocket fd, boolean active)
AbstractEpollChannel(Channel parent, LinuxSocket fd, java.net.SocketAddress remote)
AbstractEpollStreamChannel(Channel parent, int fd)
AbstractEpollStreamChannel(Channel parent, LinuxSocket fd)
AbstractEpollStreamChannel(Channel parent, LinuxSocket fd, java.net.SocketAddress remote)
EpollChannelConfig(Channel channel)
EpollChannelConfig(Channel channel, RecvByteBufAllocator recvByteBufAllocator)
EpollDomainSocketChannel(Channel parent, LinuxSocket fd)
EpollDomainSocketChannel(Channel parent, FileDescriptor fd)
EpollSocketChannel(Channel parent, LinuxSocket fd, java.net.InetSocketAddress remoteAddress)
-
Uses of Channel in io.netty.channel.group
Fields in io.netty.channel.group declared as Channel Modifier and Type Field Description private Channel
ChannelMatchers.InstanceMatcher. channel
Fields in io.netty.channel.group with type parameters of type Channel Modifier and Type Field Description private java.lang.Class<? extends Channel>
ChannelMatchers.ClassMatcher. clazz
private java.util.Collection<java.util.Map.Entry<Channel,java.lang.Throwable>>
ChannelGroupException. failed
private java.util.Map<Channel,ChannelFuture>
DefaultChannelGroupFuture. futures
private java.util.concurrent.ConcurrentMap<ChannelId,Channel>
DefaultChannelGroup. nonServerChannels
private java.util.concurrent.ConcurrentMap<ChannelId,Channel>
DefaultChannelGroup. serverChannels
Methods in io.netty.channel.group that return Channel Modifier and Type Method Description Channel
ChannelGroup. find(ChannelId id)
Channel
DefaultChannelGroup. find(ChannelId id)
Methods in io.netty.channel.group that return types with arguments of type Channel Modifier and Type Method Description java.util.Iterator<java.util.Map.Entry<Channel,java.lang.Throwable>>
ChannelGroupException. iterator()
Returns aIterator
which contains all theThrowable
that was a cause of the failure and the related id of theChannel
.java.util.Iterator<Channel>
DefaultChannelGroup. iterator()
Methods in io.netty.channel.group with parameters of type Channel Modifier and Type Method Description boolean
DefaultChannelGroup. add(Channel channel)
ChannelFuture
ChannelGroupFuture. find(Channel channel)
Returns theChannelFuture
of the individual I/O operation which is associated with the specifiedChannel
.ChannelFuture
DefaultChannelGroupFuture. find(Channel channel)
ChannelFuture
VoidChannelGroupFuture. find(Channel channel)
static ChannelMatcher
ChannelMatchers. is(Channel channel)
Returns aChannelMatcher
that matches the givenChannel
.static ChannelMatcher
ChannelMatchers. isNot(Channel channel)
Returns aChannelMatcher
that matches allChannel
s except the given.boolean
ChannelMatcher. matches(Channel channel)
Returnstrue
if the operation should be also executed on the givenChannel
.boolean
ChannelMatchers.ClassMatcher. matches(Channel ch)
boolean
ChannelMatchers.CompositeMatcher. matches(Channel channel)
boolean
ChannelMatchers.InstanceMatcher. matches(Channel ch)
boolean
ChannelMatchers.InvertMatcher. matches(Channel channel)
Method parameters in io.netty.channel.group with type arguments of type Channel Modifier and Type Method Description static ChannelMatcher
ChannelMatchers. isInstanceOf(java.lang.Class<? extends Channel> clazz)
Returns aChannelMatcher
that matches allChannel
s that are an instance of sub-type of the given class.static ChannelMatcher
ChannelMatchers. isNotInstanceOf(java.lang.Class<? extends Channel> clazz)
Returns aChannelMatcher
that matches allChannel
s that are not an instance of sub-type of the given class.Constructors in io.netty.channel.group with parameters of type Channel Constructor Description InstanceMatcher(Channel channel)
Constructor parameters in io.netty.channel.group with type arguments of type Channel Constructor Description ChannelGroupException(java.util.Collection<java.util.Map.Entry<Channel,java.lang.Throwable>> causes)
ClassMatcher(java.lang.Class<? extends Channel> clazz)
DefaultChannelGroupFuture(ChannelGroup group, java.util.Map<Channel,ChannelFuture> futures, EventExecutor executor)
-
Uses of Channel in io.netty.channel.kqueue
Classes in io.netty.channel.kqueue that implement Channel Modifier and Type Class Description (package private) class
AbstractKQueueChannel
(package private) class
AbstractKQueueDatagramChannel
class
AbstractKQueueServerChannel
class
AbstractKQueueStreamChannel
class
KQueueDatagramChannel
class
KQueueDomainDatagramChannel
class
KQueueDomainSocketChannel
class
KQueueServerDomainSocketChannel
class
KQueueServerSocketChannel
class
KQueueSocketChannel
Methods in io.netty.channel.kqueue that return Channel Modifier and Type Method Description (package private) abstract Channel
AbstractKQueueServerChannel. newChildChannel(int fd, byte[] remote, int offset, int len)
protected Channel
KQueueServerDomainSocketChannel. newChildChannel(int fd, byte[] addr, int offset, int len)
protected Channel
KQueueServerSocketChannel. newChildChannel(int fd, byte[] address, int offset, int len)
Methods in io.netty.channel.kqueue that return types with arguments of type Channel Modifier and Type Method Description java.util.Iterator<Channel>
KQueueEventLoop. registeredChannelsIterator()
Constructors in io.netty.channel.kqueue with parameters of type Channel Constructor Description AbstractKQueueChannel(Channel parent, BsdSocket fd, boolean active)
AbstractKQueueChannel(Channel parent, BsdSocket fd, java.net.SocketAddress remote)
AbstractKQueueDatagramChannel(Channel parent, BsdSocket fd, boolean active)
AbstractKQueueStreamChannel(Channel parent, BsdSocket fd, boolean active)
AbstractKQueueStreamChannel(Channel parent, BsdSocket fd, java.net.SocketAddress remote)
KQueueDomainSocketChannel(Channel parent, BsdSocket fd)
KQueueSocketChannel(Channel parent, BsdSocket fd, java.net.InetSocketAddress remoteAddress)
-
Uses of Channel in io.netty.channel.local
Classes in io.netty.channel.local that implement Channel Modifier and Type Class Description class
LocalChannel
AChannel
for the local transport.class
LocalServerChannel
AServerChannel
for the local transport which allows in VM communication.Fields in io.netty.channel.local with type parameters of type Channel Modifier and Type Field Description private static java.util.concurrent.ConcurrentMap<LocalAddress,Channel>
LocalChannelRegistry. boundChannels
Methods in io.netty.channel.local that return Channel Modifier and Type Method Description (package private) static Channel
LocalChannelRegistry. get(java.net.SocketAddress localAddress)
Methods in io.netty.channel.local with parameters of type Channel Modifier and Type Method Description (package private) static LocalAddress
LocalChannelRegistry. register(Channel channel, LocalAddress oldLocalAddress, java.net.SocketAddress localAddress)
Constructors in io.netty.channel.local with parameters of type Channel Constructor Description LocalAddress(Channel channel)
Creates a new ephemeral port based on the ID of the specified channel. -
Uses of Channel in io.netty.channel.nio
Classes in io.netty.channel.nio that implement Channel Modifier and Type Class Description class
AbstractNioByteChannel
AbstractNioChannel
base class forChannel
s that operate on bytes.class
AbstractNioChannel
Abstract base class forChannel
implementations which use a Selector based approach.class
AbstractNioMessageChannel
AbstractNioChannel
base class forChannel
s that operate on messages.Methods in io.netty.channel.nio that return types with arguments of type Channel Modifier and Type Method Description java.util.Iterator<Channel>
NioEventLoop. registeredChannelsIterator()
Constructors in io.netty.channel.nio with parameters of type Channel Constructor Description AbstractNioByteChannel(Channel parent, java.nio.channels.SelectableChannel ch)
Create a new instanceAbstractNioChannel(Channel parent, java.nio.channels.SelectableChannel ch, int readInterestOp)
Create a new instanceAbstractNioMessageChannel(Channel parent, java.nio.channels.SelectableChannel ch, int readInterestOp)
-
Uses of Channel in io.netty.channel.oio
Classes in io.netty.channel.oio that implement Channel Modifier and Type Class Description class
AbstractOioByteChannel
Deprecated.use NIO / EPOLL / KQUEUE transport.class
AbstractOioChannel
Deprecated.use NIO / EPOLL / KQUEUE transport.class
AbstractOioMessageChannel
Deprecated.use NIO / EPOLL / KQUEUE transport.class
OioByteStreamChannel
Deprecated.use NIO / EPOLL / KQUEUE transport.Constructors in io.netty.channel.oio with parameters of type Channel Constructor Description AbstractOioByteChannel(Channel parent)
Deprecated.AbstractOioChannel(Channel parent)
Deprecated.AbstractOioMessageChannel(Channel parent)
Deprecated.OioByteStreamChannel(Channel parent)
Deprecated.Create a new instance -
Uses of Channel in io.netty.channel.pool
Fields in io.netty.channel.pool with type parameters of type Channel Modifier and Type Field Description private java.util.Deque<Channel>
SimpleChannelPool. deque
private Promise<Channel>
FixedChannelPool.AcquireListener. originalPromise
(package private) Promise<Channel>
FixedChannelPool.AcquireTask. promise
Methods in io.netty.channel.pool that return Channel Modifier and Type Method Description protected Channel
SimpleChannelPool. pollChannel()
Poll aChannel
out of the internal storage to reuse it.Methods in io.netty.channel.pool that return types with arguments of type Channel Modifier and Type Method Description Future<Channel>
ChannelPool. acquire()
Acquire aChannel
from thisChannelPool
.Future<Channel>
ChannelPool. acquire(Promise<Channel> promise)
Acquire aChannel
from thisChannelPool
.Future<Channel>
FixedChannelPool. acquire(Promise<Channel> promise)
Future<Channel>
SimpleChannelPool. acquire()
Future<Channel>
SimpleChannelPool. acquire(Promise<Channel> promise)
private Future<Channel>
SimpleChannelPool. acquireHealthyFromPoolOrNew(Promise<Channel> promise)
Tries to retrieve healthy channel from the pool if any or creates a new channel otherwise.Methods in io.netty.channel.pool with parameters of type Channel Modifier and Type Method Description void
AbstractChannelPoolHandler. channelAcquired(Channel ch)
NOOP implementation, sub-classes may override this.void
ChannelPoolHandler. channelAcquired(Channel ch)
Called once aChannel
was acquired by callingChannelPool.acquire()
orChannelPool.acquire(Promise)
.void
ChannelPoolHandler. channelCreated(Channel ch)
Called once a newChannel
is created in theChannelPool
.void
AbstractChannelPoolHandler. channelReleased(Channel ch)
NOOP implementation, sub-classes may override this.void
ChannelPoolHandler. channelReleased(Channel ch)
Called once aChannel
was released by callingChannelPool.release(Channel)
orChannelPool.release(Channel, Promise)
.private void
SimpleChannelPool. closeAndFail(Channel channel, java.lang.Throwable cause, Promise<?> promise)
private void
SimpleChannelPool. closeChannel(Channel channel)
private void
SimpleChannelPool. doHealthCheck(Channel channel, Promise<Channel> promise)
private void
SimpleChannelPool. doHealthCheckOnRelease(Channel channel, Promise<java.lang.Void> promise)
private void
SimpleChannelPool. doReleaseChannel(Channel channel, Promise<java.lang.Void> promise)
Future<java.lang.Boolean>
ChannelHealthChecker. isHealthy(Channel channel)
Check if the given channel is healthy which means it can be used.private void
SimpleChannelPool. notifyHealthCheck(Future<java.lang.Boolean> future, Channel channel, Promise<Channel> promise)
protected boolean
SimpleChannelPool. offerChannel(Channel channel)
Offer aChannel
back to the internal storage.Future<java.lang.Void>
ChannelPool. release(Channel channel)
Release aChannel
back to thisChannelPool
.Future<java.lang.Void>
ChannelPool. release(Channel channel, Promise<java.lang.Void> promise)
Release aChannel
back to thisChannelPool
.Future<java.lang.Void>
FixedChannelPool. release(Channel channel, Promise<java.lang.Void> promise)
Future<java.lang.Void>
SimpleChannelPool. release(Channel channel)
Future<java.lang.Void>
SimpleChannelPool. release(Channel channel, Promise<java.lang.Void> promise)
private void
SimpleChannelPool. releaseAndOffer(Channel channel, Promise<java.lang.Void> promise)
private void
SimpleChannelPool. releaseAndOfferIfHealthy(Channel channel, Promise<java.lang.Void> promise, Future<java.lang.Boolean> future)
Adds the channel back to the pool only if the channel is healthy.Method parameters in io.netty.channel.pool with type arguments of type Channel Modifier and Type Method Description Future<Channel>
ChannelPool. acquire(Promise<Channel> promise)
Acquire aChannel
from thisChannelPool
.Future<Channel>
FixedChannelPool. acquire(Promise<Channel> promise)
Future<Channel>
SimpleChannelPool. acquire(Promise<Channel> promise)
private void
FixedChannelPool. acquire0(Promise<Channel> promise)
private Future<Channel>
SimpleChannelPool. acquireHealthyFromPoolOrNew(Promise<Channel> promise)
Tries to retrieve healthy channel from the pool if any or creates a new channel otherwise.private void
SimpleChannelPool. doHealthCheck(Channel channel, Promise<Channel> promise)
private void
SimpleChannelPool. notifyConnect(ChannelFuture future, Promise<Channel> promise)
private void
SimpleChannelPool. notifyHealthCheck(Future<java.lang.Boolean> future, Channel channel, Promise<Channel> promise)
void
FixedChannelPool.AcquireListener. operationComplete(Future<Channel> future)
Constructor parameters in io.netty.channel.pool with type arguments of type Channel Constructor Description AcquireListener(Promise<Channel> originalPromise)
AcquireTask(Promise<Channel> promise)
-
Uses of Channel in io.netty.channel.sctp
Subinterfaces of Channel in io.netty.channel.sctp Modifier and Type Interface Description interface
SctpChannel
A SCTP/IPChannel
interface for single SCTP association.interface
SctpServerChannel
A SCTP/IPServerChannel
which accepts incoming SCTP/IP associations. -
Uses of Channel in io.netty.channel.sctp.nio
Classes in io.netty.channel.sctp.nio that implement Channel Modifier and Type Class Description class
NioSctpChannel
SctpChannel
implementation which use non-blocking mode and allows to read / writeSctpMessage
s to the underlyingSctpChannel
.class
NioSctpServerChannel
SctpServerChannel
implementation which use non-blocking mode to accept new connections and create theNioSctpChannel
for them.Constructors in io.netty.channel.sctp.nio with parameters of type Channel Constructor Description NioSctpChannel(Channel parent, SctpChannel sctpChannel)
Create a new instance -
Uses of Channel in io.netty.channel.sctp.oio
Classes in io.netty.channel.sctp.oio that implement Channel Modifier and Type Class Description class
OioSctpChannel
Deprecated.useNioSctpChannel
.class
OioSctpServerChannel
Deprecated.useNioSctpServerChannel
.Constructors in io.netty.channel.sctp.oio with parameters of type Channel Constructor Description OioSctpChannel(Channel parent, SctpChannel ch)
Deprecated.Create a new instance from the givenSctpChannel
. -
Uses of Channel in io.netty.channel.socket
Subinterfaces of Channel in io.netty.channel.socket Modifier and Type Interface Description interface
DatagramChannel
A UDP/IPChannel
.interface
DuplexChannel
A duplexChannel
that has two sides that can be shutdown independently.interface
ServerSocketChannel
A TCP/IPServerChannel
which accepts incoming TCP/IP connections.interface
SocketChannel
A TCP/IP socketChannel
. -
Uses of Channel in io.netty.channel.socket.nio
Classes in io.netty.channel.socket.nio that implement Channel Modifier and Type Class Description class
NioDatagramChannel
An NIO datagramChannel
that sends and receives anAddressedEnvelope
.class
NioDomainSocketChannel
DuplexChannel
which uses NIO selector based implementation to support UNIX Domain Sockets.class
NioServerDomainSocketChannel
AServerChannel
implementation which uses NIO selector based implementation to support UNIX Domain Sockets.class
NioServerSocketChannel
AServerSocketChannel
implementation which uses NIO selector based implementation to accept new connections.class
NioSocketChannel
SocketChannel
which uses NIO selector based implementation.Constructors in io.netty.channel.socket.nio with parameters of type Channel Constructor Description NioDomainSocketChannel(Channel parent, java.nio.channels.SocketChannel socket)
Create a new instanceNioSocketChannel(Channel parent, java.nio.channels.SocketChannel socket)
Create a new instance -
Uses of Channel in io.netty.channel.socket.oio
Classes in io.netty.channel.socket.oio that implement Channel Modifier and Type Class Description class
OioDatagramChannel
Deprecated.use NIO / EPOLL / KQUEUE transport.class
OioServerSocketChannel
Deprecated.use NIO / EPOLL / KQUEUE transport.class
OioSocketChannel
Deprecated.use NIO / EPOLL / KQUEUE transport.Constructors in io.netty.channel.socket.oio with parameters of type Channel Constructor Description OioSocketChannel(Channel parent, java.net.Socket socket)
Deprecated.Create a new instance from the givenSocket
-
Uses of Channel in io.netty.channel.unix
Subinterfaces of Channel in io.netty.channel.unix Modifier and Type Interface Description interface
DomainDatagramChannel
AUnixChannel
that supports communication via UNIX domain datagram sockets.interface
DomainSocketChannel
AUnixChannel
that supports communication via Unix Domain Socket.interface
ServerDomainSocketChannel
interface
UnixChannel
Channel
that expose operations that are only present onUNIX
like systems. -
Uses of Channel in io.netty.handler.codec.http.websocketx
Methods in io.netty.handler.codec.http.websocketx with parameters of type Channel Modifier and Type Method Description ChannelFuture
WebSocketClientHandshaker. close(Channel channel, CloseWebSocketFrame frame)
Performs the closing handshake.ChannelFuture
WebSocketClientHandshaker. close(Channel channel, CloseWebSocketFrame frame, ChannelPromise promise)
Performs the closing handshake When called from within aChannelHandler
you most likely want to useWebSocketClientHandshaker.close(ChannelHandlerContext, CloseWebSocketFrame, ChannelPromise)
.ChannelFuture
WebSocketServerHandshaker. close(Channel channel, CloseWebSocketFrame frame)
Performs the closing handshake.ChannelFuture
WebSocketServerHandshaker. close(Channel channel, CloseWebSocketFrame frame, ChannelPromise promise)
Performs the closing handshake.ChannelFuture
WebSocketServerHandshaker00. close(Channel channel, CloseWebSocketFrame frame, ChannelPromise promise)
Echo back the closing frameprivate ChannelFuture
WebSocketClientHandshaker. close0(ChannelOutboundInvoker invoker, Channel channel, CloseWebSocketFrame frame, ChannelPromise promise)
void
WebSocketClientHandshaker. finishHandshake(Channel channel, FullHttpResponse response)
Validates and finishes the opening handshake initiated byWebSocketClientHandshaker.handshake(io.netty.channel.Channel)
}.(package private) static WebSocketServerHandshaker
WebSocketServerProtocolHandler. getHandshaker(Channel channel)
ChannelFuture
WebSocketClientHandshaker. handshake(Channel channel)
Begins the opening handshakeChannelFuture
WebSocketClientHandshaker. handshake(Channel channel, ChannelPromise promise)
Begins the opening handshakeChannelFuture
WebSocketServerHandshaker. handshake(Channel channel, FullHttpRequest req)
Performs the opening handshake.ChannelFuture
WebSocketServerHandshaker. handshake(Channel channel, FullHttpRequest req, HttpHeaders responseHeaders, ChannelPromise promise)
Performs the opening handshake When call this method you MUST NOT retain theFullHttpRequest
which is passed in.ChannelFuture
WebSocketServerHandshaker. handshake(Channel channel, HttpRequest req)
Performs the opening handshake.ChannelFuture
WebSocketServerHandshaker. handshake(Channel channel, HttpRequest req, HttpHeaders responseHeaders, ChannelPromise promise)
Performs the opening handshake When call this method you MUST NOT retain theHttpRequest
which is passed in.ChannelFuture
WebSocketClientHandshaker. processHandshake(Channel channel, HttpResponse response)
Process the opening handshake initiated byWebSocketClientHandshaker.handshake(io.netty.channel.Channel)
}.ChannelFuture
WebSocketClientHandshaker. processHandshake(Channel channel, HttpResponse response, ChannelPromise promise)
Process the opening handshake initiated byWebSocketClientHandshaker.handshake(io.netty.channel.Channel)
}.static ChannelFuture
WebSocketServerHandshakerFactory. sendUnsupportedVersionResponse(Channel channel)
Return that we need cannot support the web socket versionstatic ChannelFuture
WebSocketServerHandshakerFactory. sendUnsupportedVersionResponse(Channel channel, ChannelPromise promise)
Return that we need cannot support the web socket versionstatic void
WebSocketServerHandshakerFactory. sendUnsupportedWebSocketVersionResponse(Channel channel)
(package private) static void
WebSocketServerProtocolHandler. setHandshaker(Channel channel, WebSocketServerHandshaker handshaker)
-
Uses of Channel in io.netty.handler.codec.http2
Subinterfaces of Channel in io.netty.handler.codec.http2 Modifier and Type Interface Description interface
Http2StreamChannel
Classes in io.netty.handler.codec.http2 that implement Channel Modifier and Type Class Description (package private) class
AbstractHttp2StreamChannel
private class
Http2MultiplexCodec.Http2MultiplexCodecStreamChannel
Deprecated.private class
Http2MultiplexHandler.Http2MultiplexHandlerStreamChannel
Fields in io.netty.handler.codec.http2 declared as Channel Modifier and Type Field Description (package private) Channel
Http2FrameCodec.DefaultHttp2FrameStream. attachment
private Channel
Http2StreamChannelBootstrap. channel
Methods in io.netty.handler.codec.http2 that return Channel Modifier and Type Method Description private static Channel
Http2StreamFrameToHttpObjectCodec. connectionChannel(ChannelHandlerContext ctx)
Channel
AbstractHttp2StreamChannel. flush()
Channel
AbstractHttp2StreamChannel. parent()
Channel
AbstractHttp2StreamChannel. read()
Methods in io.netty.handler.codec.http2 with parameters of type Channel Modifier and Type Method Description int
AbstractHttp2StreamChannel. compareTo(Channel o)
private void
Http2StreamChannelBootstrap. init(Channel channel)
private void
AbstractHttp2StreamChannel.Http2ChannelUnsafe. invokeLater(Channel channel, java.lang.Runnable task)
private static void
Http2StreamChannelBootstrap. setAttributes(Channel channel, java.util.Map.Entry<AttributeKey<?>,java.lang.Object>[] options)
private static void
Http2StreamChannelBootstrap. setChannelOption(Channel channel, ChannelOption<?> option, java.lang.Object value)
private static void
Http2StreamChannelBootstrap. setChannelOptions(Channel channel, java.util.Map.Entry<ChannelOption<?>,java.lang.Object>[] options)
private static void
AbstractHttp2StreamChannel. windowUpdateFrameWriteComplete(ChannelFuture future, Channel streamChannel)
Constructors in io.netty.handler.codec.http2 with parameters of type Channel Constructor Description Http2StreamChannelBootstrap(Channel channel)
Http2StreamChannelConfig(Channel channel)
SimpleChannelPromiseAggregator(ChannelPromise promise, Channel c, EventExecutor e)
-
Uses of Channel in io.netty.handler.pcap
Methods in io.netty.handler.pcap with parameters of type Channel Modifier and Type Method Description private static java.net.InetSocketAddress
PcapWriteHandler. getLocalAddress(Channel ch, java.net.InetSocketAddress remote)
Get the local address of a channel. -
Uses of Channel in io.netty.handler.proxy
Methods in io.netty.handler.proxy that return types with arguments of type Channel Modifier and Type Method Description Future<Channel>
ProxyHandler. connectFuture()
Returns aFuture
that is notified when the connection to the destination has been established or the connection attempt has failed. -
Uses of Channel in io.netty.handler.ssl
Fields in io.netty.handler.ssl with type parameters of type Channel Modifier and Type Field Description private Promise<Channel>
SslHandler. handshakePromise
Methods in io.netty.handler.ssl that return types with arguments of type Channel Modifier and Type Method Description Future<Channel>
SslHandler. handshakeFuture()
Returns aFuture
that will get notified once the current TLS handshake completes.Future<Channel>
SslHandler. renegotiate()
Performs TLS renegotiation.Future<Channel>
SslHandler. renegotiate(Promise<Channel> promise)
Performs TLS renegotiation.Future<Channel>
SslHandler. sslCloseFuture()
Return theFuture
that will get notified if the inbound of theSSLEngine
is closed.Methods in io.netty.handler.ssl with parameters of type Channel Modifier and Type Method Description private void
SslHandler. setOpensslEngineSocketFd(Channel c)
Method parameters in io.netty.handler.ssl with type arguments of type Channel Modifier and Type Method Description Future<Channel>
SslHandler. renegotiate(Promise<Channel> promise)
Performs TLS renegotiation.private void
SslHandler. renegotiateOnEventLoop(Promise<Channel> newHandshakePromise)
Constructors in io.netty.handler.ssl with parameters of type Channel Constructor Description SslHandlerCoalescingBufferQueue(Channel channel, int initSize, boolean wantsDirectBuffer)
-
Uses of Channel in io.netty.resolver.dns
Fields in io.netty.resolver.dns declared as Channel Modifier and Type Field Description private Channel
DnsQueryContext. channel
private Channel
DnsResolveContext. channel
Methods in io.netty.resolver.dns that return Channel Modifier and Type Method Description (package private) Channel
DnsResolveContext. channel()
TheChannel
used.Methods in io.netty.resolver.dns with parameters of type Channel Modifier and Type Method Description (package private) Future<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>>
DnsNameResolver. doQuery(Channel channel, java.net.InetSocketAddress nameServerAddr, DnsQuestion question, DnsQueryLifecycleObserver queryLifecycleObserver, DnsRecord[] additionals, boolean flush, Promise<AddressedEnvelope<? extends DnsResponse,java.net.InetSocketAddress>> promise)
private void
DnsNameResolver. doResolveAllUncached(Channel channel, java.lang.String hostname, DnsRecord[] additionals, Promise<?> originalPromise, Promise<java.util.List<java.net.InetAddress>> promise, DnsCache resolveCache, boolean completeEarlyIfPossible)
private void
DnsNameResolver. doResolveAllUncached0(Channel channel, java.lang.String hostname, DnsRecord[] additionals, Promise<?> originalPromise, Promise<java.util.List<java.net.InetAddress>> promise, DnsCache resolveCache, boolean completeEarlyIfPossible)
private void
DnsNameResolver. doResolveUncached(Channel channel, java.lang.String hostname, DnsRecord[] additionals, Promise<java.net.InetAddress> promise, DnsCache resolveCache, boolean completeEarlyIfPossible)
(package private) DnsResolveContext<java.net.InetAddress>
DnsAddressResolveContext. newResolverContext(DnsNameResolver parent, Channel channel, Promise<?> originalPromise, java.lang.String hostname, int dnsClass, DnsRecordType[] expectedTypes, DnsRecord[] additionals, DnsServerAddressStream nameServerAddrs, int allowedQueries)
(package private) DnsResolveContext<DnsRecord>
DnsRecordResolveContext. newResolverContext(DnsNameResolver parent, Channel channel, Promise<?> originalPromise, java.lang.String hostname, int dnsClass, DnsRecordType[] expectedTypes, DnsRecord[] additionals, DnsServerAddressStream nameServerAddrs, int allowedQueries)
(package private) abstract DnsResolveContext<T>
DnsResolveContext. newResolverContext(DnsNameResolver parent, Channel channel, Promise<?> originalPromise, java.lang.String hostname, int dnsClass, DnsRecordType[] expectedTypes, DnsRecord[] additionals, DnsServerAddressStream nameServerAddrs, int allowedQueries)
Creates a new context with the given parameters.private void
DnsNameResolver. resolveNow(Channel channel, java.lang.String hostname, DnsRecord[] additionals, Promise<?> originalPromise, Promise<java.util.List<java.net.InetAddress>> promise, DnsCache resolveCache, boolean completeEarlyIfPossible)
Constructors in io.netty.resolver.dns with parameters of type Channel Constructor Description DatagramDnsQueryContext(Channel channel, java.net.InetSocketAddress nameServerAddr, DnsQueryContextManager queryContextManager, int maxPayLoadSize, boolean recursionDesired, long queryTimeoutMillis, DnsQuestion question, DnsRecord[] additionals, Promise<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>> promise, Bootstrap socketBootstrap, boolean retryWithTcpOnTimeout)
DnsAddressResolveContext(DnsNameResolver parent, Channel channel, Promise<?> originalPromise, java.lang.String hostname, DnsRecord[] additionals, DnsServerAddressStream nameServerAddrs, int allowedQueries, DnsCache resolveCache, AuthoritativeDnsServerCache authoritativeDnsServerCache, boolean completeEarlyIfPossible)
DnsQueryContext(Channel channel, java.net.InetSocketAddress nameServerAddr, DnsQueryContextManager queryContextManager, int maxPayLoadSize, boolean recursionDesired, long queryTimeoutMillis, DnsQuestion question, DnsRecord[] additionals, Promise<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>> promise, Bootstrap socketBootstrap, boolean retryWithTcpOnTimeout)
DnsRecordResolveContext(DnsNameResolver parent, Channel channel, Promise<?> originalPromise, DnsQuestion question, DnsRecord[] additionals, DnsServerAddressStream nameServerAddrs, int allowedQueries)
DnsRecordResolveContext(DnsNameResolver parent, Channel channel, Promise<?> originalPromise, java.lang.String hostname, int dnsClass, DnsRecordType[] expectedTypes, DnsRecord[] additionals, DnsServerAddressStream nameServerAddrs, int allowedQueries)
DnsResolveContext(DnsNameResolver parent, Channel channel, Promise<?> originalPromise, java.lang.String hostname, int dnsClass, DnsRecordType[] expectedTypes, DnsRecord[] additionals, DnsServerAddressStream nameServerAddrs, int allowedQueries)
TcpDnsQueryContext(Channel channel, java.net.InetSocketAddress nameServerAddr, DnsQueryContextManager queryContextManager, int maxPayLoadSize, boolean recursionDesired, long queryTimeoutMillis, DnsQuestion question, DnsRecord[] additionals, Promise<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>> promise)
-