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 virtual
Channel 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 open
Channel s and perform bulk operations on them. |
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 for
Channel 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.ssl |
SSL ·
TLS implementation based on
SSLEngine |
Modifier and Type | Class and Description |
---|---|
class |
AbstractBootstrap<B extends AbstractBootstrap<B,C>,C extends Channel>
AbstractBootstrap is a helper class that makes it easy to bootstrap a Channel . |
private static class |
AbstractBootstrap.BootstrapChannelFactory<T extends Channel> |
interface |
ChannelFactory<T extends Channel>
Factory that creates a new
Channel on AbstractBootstrap.bind() , Bootstrap.connect() , and
AbstractBootstrap.bind() . |
Modifier and Type | Method and Description |
---|---|
private static void |
AbstractBootstrap.doBind0(ChannelFuture regFuture,
Channel channel,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
private static void |
Bootstrap.doConnect0(ChannelFuture regFuture,
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) void |
ServerBootstrap.init(Channel channel) |
(package private) abstract void |
AbstractBootstrap.init(Channel channel) |
(package private) void |
Bootstrap.init(Channel channel) |
Constructor and Description |
---|
PendingRegistrationPromise(Channel channel) |
Modifier and Type | Class and Description |
---|---|
class |
ChannelInitializer<C extends Channel>
A special
ChannelInboundHandler which offers an easy way to initialize a Channel once it was
registered to its EventLoop . |
Modifier and Type | Interface and Description |
---|---|
interface |
ServerChannel
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractChannel
A skeletal
Channel implementation. |
class |
AbstractServerChannel
A skeletal server-side
Channel implementation. |
Modifier and Type | Field and Description |
---|---|
private Channel |
ThreadPerChannelEventLoop.ch |
private Channel |
DefaultChannelProgressivePromise.channel |
protected Channel |
DefaultChannelConfig.channel |
private Channel |
CompleteChannelFuture.channel |
private Channel |
DefaultChannelPromise.channel |
private Channel |
VoidChannelPromise.channel |
private Channel |
ChannelOutboundBuffer.channel |
private Channel |
DefaultChannelPipeline.channel |
private Channel |
AbstractChannel.parent |
Modifier and Type | Method and Description |
---|---|
Channel |
ChannelFuture.channel()
Returns a channel where the I/O operation associated with this
future takes place.
|
Channel |
DefaultChannelProgressivePromise.channel() |
Channel |
CompleteChannelFuture.channel() |
Channel |
ChannelPromise.channel() |
Channel |
AbstractChannelHandlerContext.channel() |
Channel |
DefaultChannelPromise.channel() |
Channel |
VoidChannelPromise.channel() |
Channel |
ChannelPipeline.channel()
Returns the
Channel that this pipeline is attached to. |
Channel |
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.channel() |
Channel |
DefaultChannelPipeline.channel() |
Channel |
ChannelHandlerContext.channel()
Return the
Channel which is bound to the ChannelHandlerContext . |
Channel |
AbstractChannel.flush() |
Channel |
Channel.flush()
Request to flush all pending messages.
|
Channel |
AbstractChannel.parent() |
Channel |
Channel.parent()
Returns the parent of this channel.
|
Channel |
AbstractChannel.read() |
Channel |
Channel.read()
Request to Read data from the
Channel into the first inbound buffer, triggers an
ChannelInboundHandler.channelRead(ChannelHandlerContext, Object) event if data was
read, and triggers a
channelReadComplete event so the
handler can decide to continue reading. |
Modifier and Type | Method and Description |
---|---|
int |
AbstractChannel.compareTo(Channel o) |
ChannelFuture |
MultithreadEventLoopGroup.register(Channel channel) |
ChannelFuture |
SingleThreadEventLoop.register(Channel channel) |
ChannelFuture |
ThreadPerChannelEventLoopGroup.register(Channel channel) |
ChannelFuture |
EventLoopGroup.register(Channel channel)
|
ChannelFuture |
MultithreadEventLoopGroup.register(Channel channel,
ChannelPromise promise) |
ChannelFuture |
SingleThreadEventLoop.register(Channel channel,
ChannelPromise promise) |
ChannelFuture |
ThreadPerChannelEventLoop.register(Channel channel,
ChannelPromise promise) |
ChannelFuture |
ThreadPerChannelEventLoopGroup.register(Channel channel,
ChannelPromise promise) |
ChannelFuture |
EventLoopGroup.register(Channel channel,
ChannelPromise promise)
|
Constructor and Description |
---|
AbstractChannel(Channel parent)
Creates a new instance.
|
CompleteChannelFuture(Channel channel,
EventExecutor executor)
Creates a new instance.
|
DefaultChannelConfig(Channel channel) |
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.
|
SucceededChannelFuture(Channel channel,
EventExecutor executor)
Creates a new instance.
|
VoidChannelPromise(Channel channel,
boolean fireException)
Creates a new instance.
|
Modifier and Type | Class and Description |
---|---|
class |
EmbeddedChannel
Base class for
Channel implementations that are used in an embedded fashion. |
Modifier and Type | Method and Description |
---|---|
ChannelFuture |
EmbeddedEventLoop.register(Channel channel) |
ChannelFuture |
EmbeddedEventLoop.register(Channel channel,
ChannelPromise promise) |
Modifier and Type | Class and Description |
---|---|
(package private) class |
AbstractEpollChannel |
class |
AbstractEpollServerChannel |
class |
AbstractEpollStreamChannel |
class |
EpollDatagramChannel
DatagramChannel implementation that uses linux EPOLL Edge-Triggered Mode for
maximal performance. |
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. |
Modifier and Type | Method and Description |
---|---|
(package private) 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) |
Constructor and Description |
---|
AbstractEpollChannel(Channel parent,
Socket fd,
int flag,
boolean active) |
AbstractEpollStreamChannel(Channel parent,
int fd)
|
AbstractEpollStreamChannel(Channel parent,
Socket fd) |
EpollDomainSocketChannel(Channel parent,
FileDescriptor fd)
Deprecated.
|
EpollDomainSocketChannel(Channel parent,
Socket fd) |
EpollSocketChannel(Channel parent,
Socket fd,
java.net.InetSocketAddress remote) |
Modifier and Type | Field and Description |
---|---|
private Channel |
ChannelMatchers.InstanceMatcher.channel |
Modifier and Type | Field and 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 ConcurrentSet<Channel> |
DefaultChannelGroup.nonServerChannels |
private ConcurrentSet<Channel> |
DefaultChannelGroup.serverChannels |
Modifier and Type | Method and Description |
---|---|
java.util.Iterator<Channel> |
DefaultChannelGroup.iterator() |
java.util.Iterator<java.util.Map.Entry<Channel,java.lang.Throwable>> |
ChannelGroupException.iterator()
Returns a
Iterator which contains all the Throwable that was a cause of the failure and the
related id of the Channel . |
Modifier and Type | Method and Description |
---|---|
boolean |
DefaultChannelGroup.add(Channel channel) |
ChannelFuture |
DefaultChannelGroupFuture.find(Channel channel) |
ChannelFuture |
ChannelGroupFuture.find(Channel channel)
Returns the
ChannelFuture of the individual I/O operation which
is associated with the specified Channel . |
static ChannelMatcher |
ChannelMatchers.is(Channel channel)
Returns a
ChannelMatcher that matches the given Channel . |
static ChannelMatcher |
ChannelMatchers.isNot(Channel channel)
Returns a
ChannelMatcher that matches all Channel s except the given. |
boolean |
ChannelMatchers.CompositeMatcher.matches(Channel channel) |
boolean |
ChannelMatchers.InvertMatcher.matches(Channel channel) |
boolean |
ChannelMatchers.InstanceMatcher.matches(Channel ch) |
boolean |
ChannelMatchers.ClassMatcher.matches(Channel ch) |
boolean |
ChannelMatcher.matches(Channel channel)
Returns
true if the operation should be also executed on the given Channel . |
Modifier and Type | Method and Description |
---|---|
static ChannelMatcher |
ChannelMatchers.isInstanceOf(java.lang.Class<? extends Channel> clazz)
Returns a
ChannelMatcher that matches all Channel s that are an instance of sub-type of
the given class. |
static ChannelMatcher |
ChannelMatchers.isNotInstanceOf(java.lang.Class<? extends Channel> clazz)
Returns a
ChannelMatcher that matches all Channel s that are not an
instance of sub-type of the given class. |
Constructor and Description |
---|
InstanceMatcher(Channel channel) |
Constructor and 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) |
Modifier and Type | Class and Description |
---|---|
class |
LocalChannel
A
Channel for the local transport. |
class |
LocalServerChannel
A
ServerChannel for the local transport which allows in VM communication. |
Modifier and Type | Field and Description |
---|---|
private static java.util.concurrent.ConcurrentMap<LocalAddress,Channel> |
LocalChannelRegistry.boundChannels |
Modifier and Type | Method and Description |
---|---|
(package private) static Channel |
LocalChannelRegistry.get(java.net.SocketAddress localAddress) |
Modifier and Type | Method and Description |
---|---|
(package private) static LocalAddress |
LocalChannelRegistry.register(Channel channel,
LocalAddress oldLocalAddress,
java.net.SocketAddress localAddress) |
Constructor and Description |
---|
LocalAddress(Channel channel)
Creates a new ephemeral port based on the ID of the specified channel.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractNioByteChannel
AbstractNioChannel base class for Channel s that operate on bytes. |
class |
AbstractNioChannel
Abstract base class for
Channel implementations which use a Selector based approach. |
class |
AbstractNioMessageChannel
AbstractNioChannel base class for Channel s that operate on messages. |
Constructor and Description |
---|
AbstractNioByteChannel(Channel parent,
java.nio.channels.SelectableChannel ch)
Create a new instance
|
AbstractNioChannel(Channel parent,
java.nio.channels.SelectableChannel ch,
int readInterestOp)
Create a new instance
|
AbstractNioMessageChannel(Channel parent,
java.nio.channels.SelectableChannel ch,
int readInterestOp) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractOioByteChannel
Abstract base class for OIO which reads and writes bytes from/to a Socket
|
class |
AbstractOioChannel
Abstract base class for
Channel implementations that use Old-Blocking-IO |
class |
AbstractOioMessageChannel
Abstract base class for OIO which reads and writes objects from/to a Socket
|
class |
OioByteStreamChannel
Abstract base class for OIO Channels that are based on streams.
|
Constructor and Description |
---|
AbstractOioByteChannel(Channel parent) |
AbstractOioChannel(Channel parent) |
AbstractOioMessageChannel(Channel parent) |
OioByteStreamChannel(Channel parent)
Create a new instance
|
Modifier and Type | Field and Description |
---|---|
private java.util.Deque<Channel> |
SimpleChannelPool.deque |
private Promise<Channel> |
FixedChannelPool.AcquireListener.originalPromise |
(package private) Promise<Channel> |
FixedChannelPool.AcquireTask.promise |
Modifier and Type | Method and Description |
---|---|
protected Channel |
SimpleChannelPool.pollChannel()
Poll a
Channel out of the internal storage to reuse it. |
Modifier and Type | Method and Description |
---|---|
Future<Channel> |
ChannelPool.acquire()
Acquire a
Channel from this ChannelPool . |
Future<Channel> |
SimpleChannelPool.acquire() |
Future<Channel> |
ChannelPool.acquire(Promise<Channel> promise)
Acquire a
Channel from this ChannelPool . |
Future<Channel> |
SimpleChannelPool.acquire(Promise<Channel> promise) |
Future<Channel> |
FixedChannelPool.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.
|
Modifier and Type | Method and Description |
---|---|
void |
ChannelPoolHandler.channelAcquired(Channel ch)
Called once a
Channel was acquired by calling ChannelPool.acquire() or
ChannelPool.acquire(Promise) . |
void |
AbstractChannelPoolHandler.channelAcquired(Channel ch)
NOOP implementation, sub-classes may override this.
|
void |
ChannelPoolHandler.channelCreated(Channel ch)
Called once a new
Channel is created in the ChannelPool . |
void |
ChannelPoolHandler.channelReleased(Channel ch)
Called once a
Channel was released by calling ChannelPool.release(Channel) or
ChannelPool.release(Channel, Promise) . |
void |
AbstractChannelPoolHandler.channelReleased(Channel ch)
NOOP implementation, sub-classes may override this.
|
private static void |
SimpleChannelPool.closeAndFail(Channel channel,
java.lang.Throwable cause,
Promise<?> promise) |
private static void |
SimpleChannelPool.closeChannel(Channel channel) |
private void |
SimpleChannelPool.doHealthCheck(Channel ch,
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 ch,
Promise<Channel> promise) |
protected boolean |
SimpleChannelPool.offerChannel(Channel channel)
Offer a
Channel back to the internal storage. |
Future<java.lang.Void> |
ChannelPool.release(Channel channel)
Release a
Channel back to this ChannelPool . |
Future<java.lang.Void> |
SimpleChannelPool.release(Channel channel) |
Future<java.lang.Void> |
ChannelPool.release(Channel channel,
Promise<java.lang.Void> promise)
Release a
Channel back to this ChannelPool . |
Future<java.lang.Void> |
SimpleChannelPool.release(Channel channel,
Promise<java.lang.Void> promise) |
Future<java.lang.Void> |
FixedChannelPool.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 healty.
|
Modifier and Type | Method and Description |
---|---|
Future<Channel> |
ChannelPool.acquire(Promise<Channel> promise)
Acquire a
Channel from this ChannelPool . |
Future<Channel> |
SimpleChannelPool.acquire(Promise<Channel> promise) |
Future<Channel> |
FixedChannelPool.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 ch,
Promise<Channel> promise) |
private void |
SimpleChannelPool.notifyConnect(ChannelFuture future,
Promise<Channel> promise) |
private void |
SimpleChannelPool.notifyHealthCheck(Future<java.lang.Boolean> future,
Channel ch,
Promise<Channel> promise) |
void |
FixedChannelPool.AcquireListener.operationComplete(Future<Channel> future) |
Constructor and Description |
---|
AcquireListener(Promise<Channel> originalPromise) |
AcquireTask(Promise<Channel> promise) |
Modifier and Type | Interface and Description |
---|---|
interface |
SctpChannel
A SCTP/IP
Channel interface for single SCTP association. |
interface |
SctpServerChannel
A SCTP/IP
ServerChannel which accepts incoming SCTP/IP associations. |
Modifier and Type | Class and Description |
---|---|
class |
NioSctpChannel
SctpChannel implementation which use non-blocking mode and allows to read /
write SctpMessage s to the underlying SctpChannel . |
class |
NioSctpServerChannel
SctpServerChannel implementation which use non-blocking mode to accept new
connections and create the NioSctpChannel for them. |
Constructor and Description |
---|
NioSctpChannel(Channel parent,
SctpChannel sctpChannel)
Create a new instance
|
Modifier and Type | Class and Description |
---|---|
class |
OioSctpChannel
SctpChannel implementation which use blocking mode and allows to read / write
SctpMessage s to the underlying SctpChannel . |
class |
OioSctpServerChannel
SctpServerChannel implementation which use blocking mode to accept new
connections and create the OioSctpChannel for them. |
Constructor and Description |
---|
OioSctpChannel(Channel parent,
SctpChannel ch)
Create a new instance from the given
SctpChannel . |
Modifier and Type | Interface and Description |
---|---|
interface |
DatagramChannel
A UDP/IP
Channel . |
interface |
DuplexChannel
A duplex
Channel that has two sides that can be shutdown independently. |
interface |
ServerSocketChannel
A TCP/IP
ServerChannel which accepts incoming TCP/IP connections. |
interface |
SocketChannel
A TCP/IP socket
Channel . |
Modifier and Type | Class and Description |
---|---|
class |
NioDatagramChannel
An NIO datagram
Channel that sends and receives an
AddressedEnvelope . |
class |
NioServerSocketChannel
A
ServerSocketChannel implementation which uses
NIO selector based implementation to accept new connections. |
class |
NioSocketChannel
SocketChannel which uses NIO selector based implementation. |
Constructor and Description |
---|
NioSocketChannel(Channel parent,
java.nio.channels.SocketChannel socket)
Create a new instance
|
Modifier and Type | Class and Description |
---|---|
class |
OioDatagramChannel
An OIO datagram
Channel that sends and receives an
AddressedEnvelope . |
class |
OioServerSocketChannel
ServerSocketChannel which accepts new connections and create the OioSocketChannel 's for them. |
class |
OioSocketChannel
A
SocketChannel which is using Old-Blocking-IO |
Constructor and Description |
---|
OioSocketChannel(Channel parent,
java.net.Socket socket)
Create a new instance from the given
Socket |
Modifier and Type | Interface and Description |
---|---|
interface |
DomainSocketChannel
A
UnixChannel that supports communication via
Unix Domain Socket. |
interface |
ServerDomainSocketChannel
|
interface |
UnixChannel
Channel that expose operations that are only present on UNIX like systems. |
Modifier and Type | Method and Description |
---|---|
ChannelFuture |
WebSocketClientHandshaker.close(Channel channel,
CloseWebSocketFrame frame)
Performs the closing handshake
|
ChannelFuture |
WebSocketServerHandshaker.close(Channel channel,
CloseWebSocketFrame frame)
Performs the closing handshake
|
ChannelFuture |
WebSocketServerHandshaker00.close(Channel channel,
CloseWebSocketFrame frame,
ChannelPromise promise)
Echo back the closing frame
|
ChannelFuture |
WebSocketClientHandshaker.close(Channel channel,
CloseWebSocketFrame frame,
ChannelPromise promise)
Performs the closing handshake
|
ChannelFuture |
WebSocketServerHandshaker.close(Channel channel,
CloseWebSocketFrame frame,
ChannelPromise promise)
Performs the closing handshake
|
void |
WebSocketClientHandshaker.finishHandshake(Channel channel,
FullHttpResponse response)
Validates and finishes the opening handshake initiated by
WebSocketClientHandshaker.handshake(io.netty.channel.Channel) }. |
(package private) static WebSocketServerHandshaker |
WebSocketServerProtocolHandler.getHandshaker(Channel channel) |
ChannelFuture |
WebSocketClientHandshaker.handshake(Channel channel)
Begins the opening handshake
|
ChannelFuture |
WebSocketClientHandshaker.handshake(Channel channel,
ChannelPromise promise)
Begins the opening handshake
|
ChannelFuture |
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 the
FullHttpRequest 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 the
HttpRequest which is passed in. |
ChannelFuture |
WebSocketClientHandshaker.processHandshake(Channel channel,
HttpResponse response)
Process the opening handshake initiated by
WebSocketClientHandshaker.handshake(io.netty.channel.Channel) }. |
ChannelFuture |
WebSocketClientHandshaker.processHandshake(Channel channel,
HttpResponse response,
ChannelPromise promise)
Process the opening handshake initiated by
WebSocketClientHandshaker.handshake(io.netty.channel.Channel) }. |
static ChannelFuture |
WebSocketServerHandshakerFactory.sendUnsupportedVersionResponse(Channel channel)
Return that we need cannot not support the web socket version
|
static ChannelFuture |
WebSocketServerHandshakerFactory.sendUnsupportedVersionResponse(Channel channel,
ChannelPromise promise)
Return that we need cannot not support the web socket version
|
static void |
WebSocketServerHandshakerFactory.sendUnsupportedWebSocketVersionResponse(Channel channel)
|
(package private) static void |
WebSocketServerProtocolHandler.setHandshaker(Channel channel,
WebSocketServerHandshaker handshaker) |
Modifier and Type | Field and Description |
---|---|
private Promise<Channel> |
SslHandler.handshakePromise |
Modifier and Type | Method and Description |
---|---|
Future<Channel> |
SslHandler.handshakeFuture()
Returns a
Future 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 the
Future that will get notified if the inbound of the SSLEngine is closed. |
Modifier and Type | Method and Description |
---|---|
private void |
SslHandler.handshake(Promise<Channel> newHandshakePromise)
Performs TLS (re)negotiation.
|
Future<Channel> |
SslHandler.renegotiate(Promise<Channel> promise)
Performs TLS renegotiation.
|