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.handler.codec |
Extensible decoder and its common implementations which deal with the
packet fragmentation and reassembly issue found in a stream-based transport
such as TCP/IP.
|
io.netty.handler.codec.base64 | |
io.netty.handler.codec.bytes |
Encoder and decoder which transform an array of bytes into a
ByteBuf and vice versa. |
io.netty.handler.codec.compression | |
io.netty.handler.codec.dns |
DNS codec.
|
io.netty.handler.codec.haproxy |
Decodes an HAProxy proxy protocol header
|
io.netty.handler.codec.json |
JSON specific codecs.
|
io.netty.handler.codec.memcache |
Common superset of ascii and binary classes.
|
io.netty.handler.codec.memcache.binary |
Implementations and Interfaces for the Memcache Binary protocol.
|
io.netty.handler.codec.mqtt |
Encoder, decoder and different Message Types for MQTT.
|
io.netty.handler.codec.redis |
Encoder, decoder for Redis.
|
io.netty.handler.codec.sctp |
Decoder and encoders to manage message completion and multi-streaming codec in SCTP/IP.
|
io.netty.handler.codec.serialization |
Encoder, decoder and their compatibility stream implementations which
transform a
Serializable object into a byte buffer and
vice versa. |
io.netty.handler.codec.smtp |
SMTP codec.
|
io.netty.handler.codec.socks |
Encoder, decoder and their related message types for Socks.
|
io.netty.handler.codec.socksx |
Encoder, decoder and their related message types for SOCKS protocol.
|
io.netty.handler.codec.socksx.v4 |
Encoder, decoder and their related message types for SOCKSv4 protocol.
|
io.netty.handler.codec.socksx.v5 |
Encoder, decoder and their related message types for SOCKSv5 protocol.
|
io.netty.handler.codec.stomp |
STOMP codec
|
io.netty.handler.codec.string |
Encoder and decoder which transform a
String into a
ByteBuf and vice versa. |
io.netty.handler.codec.xml |
Xml specific codecs.
|
io.netty.handler.flow |
Package to control the flow of messages.
|
io.netty.handler.flush |
Package to control flush behavior.
|
io.netty.handler.ipfilter |
Package to filter IP addresses (allow/deny).
|
io.netty.handler.logging |
Logs the I/O events for debugging purpose.
|
io.netty.handler.ssl |
SSL ·
TLS implementation based on
SSLEngine |
io.netty.handler.stream |
Writes very large data stream asynchronously neither spending a lot of
memory nor getting
OutOfMemoryError . |
io.netty.handler.timeout |
Adds support for read and write timeout and idle connection notification
using a
Timer . |
io.netty.handler.traffic |
Implementation of a Traffic Shaping Handler and Dynamic Statistics.
|
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.
|
Modifier and Type | Method and Description |
---|---|
void |
ServerBootstrap.ServerBootstrapAcceptor.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
ServerBootstrap.ServerBootstrapAcceptor.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
Modifier and Type | Class and Description |
---|---|
(package private) class |
AbstractChannelHandlerContext |
private static class |
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext |
(package private) class |
DefaultChannelHandlerContext |
(package private) class |
DefaultChannelPipeline.HeadContext |
(package private) class |
DefaultChannelPipeline.TailContext |
Modifier and Type | Field and Description |
---|---|
private ChannelHandlerContext |
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.ctx |
private ChannelHandlerContext |
PendingWriteQueue.ctx |
Modifier and Type | Field and Description |
---|---|
private java.util.concurrent.ConcurrentMap<ChannelHandlerContext,java.lang.Boolean> |
ChannelInitializer.initMap |
Modifier and Type | Method and Description |
---|---|
ChannelHandlerContext |
ChannelPipeline.context(ChannelHandler handler)
Returns the context object of the specified
ChannelHandler in
this pipeline. |
ChannelHandlerContext |
DefaultChannelPipeline.context(ChannelHandler handler) |
ChannelHandlerContext |
ChannelPipeline.context(java.lang.Class<? extends ChannelHandler> handlerType)
Returns the context object of the
ChannelHandler of the
specified type in this pipeline. |
ChannelHandlerContext |
DefaultChannelPipeline.context(java.lang.Class<? extends ChannelHandler> handlerType) |
ChannelHandlerContext |
ChannelPipeline.context(java.lang.String name)
Returns the context object of the
ChannelHandler with the
specified name in this pipeline. |
ChannelHandlerContext |
DefaultChannelPipeline.context(java.lang.String name) |
ChannelHandlerContext |
AbstractChannelHandlerContext.fireChannelActive() |
ChannelHandlerContext |
ChannelHandlerContext.fireChannelActive() |
ChannelHandlerContext |
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.fireChannelActive() |
ChannelHandlerContext |
AbstractChannelHandlerContext.fireChannelInactive() |
ChannelHandlerContext |
ChannelHandlerContext.fireChannelInactive() |
ChannelHandlerContext |
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.fireChannelInactive() |
ChannelHandlerContext |
AbstractChannelHandlerContext.fireChannelRead(java.lang.Object msg) |
ChannelHandlerContext |
ChannelHandlerContext.fireChannelRead(java.lang.Object msg) |
ChannelHandlerContext |
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.fireChannelRead(java.lang.Object msg) |
ChannelHandlerContext |
AbstractChannelHandlerContext.fireChannelReadComplete() |
ChannelHandlerContext |
ChannelHandlerContext.fireChannelReadComplete() |
ChannelHandlerContext |
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.fireChannelReadComplete() |
ChannelHandlerContext |
AbstractChannelHandlerContext.fireChannelRegistered() |
ChannelHandlerContext |
ChannelHandlerContext.fireChannelRegistered() |
ChannelHandlerContext |
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.fireChannelRegistered() |
ChannelHandlerContext |
AbstractChannelHandlerContext.fireChannelUnregistered() |
ChannelHandlerContext |
ChannelHandlerContext.fireChannelUnregistered() |
ChannelHandlerContext |
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.fireChannelUnregistered() |
ChannelHandlerContext |
AbstractChannelHandlerContext.fireChannelWritabilityChanged() |
ChannelHandlerContext |
ChannelHandlerContext.fireChannelWritabilityChanged() |
ChannelHandlerContext |
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.fireChannelWritabilityChanged() |
ChannelHandlerContext |
AbstractChannelHandlerContext.fireExceptionCaught(java.lang.Throwable cause) |
ChannelHandlerContext |
ChannelHandlerContext.fireExceptionCaught(java.lang.Throwable cause) |
ChannelHandlerContext |
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.fireExceptionCaught(java.lang.Throwable cause) |
ChannelHandlerContext |
AbstractChannelHandlerContext.fireUserEventTriggered(java.lang.Object event) |
ChannelHandlerContext |
ChannelHandlerContext.fireUserEventTriggered(java.lang.Object evt) |
ChannelHandlerContext |
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.fireUserEventTriggered(java.lang.Object event) |
ChannelHandlerContext |
ChannelPipeline.firstContext()
Returns the context of the first
ChannelHandler in this pipeline. |
ChannelHandlerContext |
DefaultChannelPipeline.firstContext() |
ChannelHandlerContext |
AbstractChannelHandlerContext.flush() |
ChannelHandlerContext |
ChannelHandlerContext.flush() |
ChannelHandlerContext |
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.flush() |
ChannelHandlerContext |
ChannelPipeline.lastContext()
Returns the context of the last
ChannelHandler in this pipeline. |
ChannelHandlerContext |
DefaultChannelPipeline.lastContext() |
ChannelHandlerContext |
AbstractChannelHandlerContext.read() |
ChannelHandlerContext |
ChannelHandlerContext.read() |
ChannelHandlerContext |
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.read() |
Modifier and Type | Method and Description |
---|---|
void |
ChannelDuplexHandler.bind(ChannelHandlerContext ctx,
java.net.SocketAddress localAddress,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.bind(SocketAddress, ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
ChannelOutboundHandler.bind(ChannelHandlerContext ctx,
java.net.SocketAddress localAddress,
ChannelPromise promise)
Called once a bind operation is made.
|
void |
ChannelOutboundHandlerAdapter.bind(ChannelHandlerContext ctx,
java.net.SocketAddress localAddress,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.bind(SocketAddress, ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
CombinedChannelDuplexHandler.bind(ChannelHandlerContext ctx,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
void |
DefaultChannelPipeline.HeadContext.bind(ChannelHandlerContext ctx,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
void |
ChannelInboundHandler.channelActive(ChannelHandlerContext ctx)
The
Channel of the ChannelHandlerContext is now active |
void |
ChannelInboundHandlerAdapter.channelActive(ChannelHandlerContext ctx)
|
void |
CombinedChannelDuplexHandler.channelActive(ChannelHandlerContext ctx) |
void |
DefaultChannelPipeline.TailContext.channelActive(ChannelHandlerContext ctx) |
void |
DefaultChannelPipeline.HeadContext.channelActive(ChannelHandlerContext ctx) |
void |
ChannelInboundHandler.channelInactive(ChannelHandlerContext ctx)
The
Channel of the ChannelHandlerContext was registered is now inactive and reached its
end of lifetime. |
void |
ChannelInboundHandlerAdapter.channelInactive(ChannelHandlerContext ctx)
|
void |
CombinedChannelDuplexHandler.channelInactive(ChannelHandlerContext ctx) |
void |
DefaultChannelPipeline.TailContext.channelInactive(ChannelHandlerContext ctx) |
void |
DefaultChannelPipeline.HeadContext.channelInactive(ChannelHandlerContext ctx) |
void |
ChannelInboundHandler.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg)
Invoked when the current
Channel has read a message from the peer. |
void |
ChannelInboundHandlerAdapter.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg)
|
void |
CombinedChannelDuplexHandler.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
DefaultChannelPipeline.TailContext.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
DefaultChannelPipeline.HeadContext.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
SimpleChannelInboundHandler.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
protected abstract void |
SimpleChannelInboundHandler.channelRead0(ChannelHandlerContext ctx,
I msg)
Please keep in mind that this method will be renamed to
messageReceived(ChannelHandlerContext, I) in 5.0.
Is called for each message of type I . |
void |
ChannelInboundHandler.channelReadComplete(ChannelHandlerContext ctx)
Invoked when the last message read by the current read operation has been consumed by
ChannelInboundHandler.channelRead(ChannelHandlerContext, Object) . |
void |
ChannelInboundHandlerAdapter.channelReadComplete(ChannelHandlerContext ctx)
Calls
fireChannelReadComplete() to forward
to the next ChannelInboundHandler in the ChannelPipeline . |
void |
CombinedChannelDuplexHandler.channelReadComplete(ChannelHandlerContext ctx) |
void |
DefaultChannelPipeline.TailContext.channelReadComplete(ChannelHandlerContext ctx) |
void |
DefaultChannelPipeline.HeadContext.channelReadComplete(ChannelHandlerContext ctx) |
void |
ChannelInboundHandler.channelRegistered(ChannelHandlerContext ctx)
|
void |
ChannelInboundHandlerAdapter.channelRegistered(ChannelHandlerContext ctx)
|
void |
ChannelInitializer.channelRegistered(ChannelHandlerContext ctx) |
void |
CombinedChannelDuplexHandler.channelRegistered(ChannelHandlerContext ctx) |
void |
DefaultChannelPipeline.TailContext.channelRegistered(ChannelHandlerContext ctx) |
void |
DefaultChannelPipeline.HeadContext.channelRegistered(ChannelHandlerContext ctx) |
void |
ChannelInboundHandler.channelUnregistered(ChannelHandlerContext ctx)
|
void |
ChannelInboundHandlerAdapter.channelUnregistered(ChannelHandlerContext ctx)
Calls
fireChannelUnregistered() to forward
to the next ChannelInboundHandler in the ChannelPipeline . |
void |
CombinedChannelDuplexHandler.channelUnregistered(ChannelHandlerContext ctx) |
void |
DefaultChannelPipeline.TailContext.channelUnregistered(ChannelHandlerContext ctx) |
void |
DefaultChannelPipeline.HeadContext.channelUnregistered(ChannelHandlerContext ctx) |
void |
ChannelInboundHandler.channelWritabilityChanged(ChannelHandlerContext ctx)
Gets called once the writable state of a
Channel changed. |
void |
ChannelInboundHandlerAdapter.channelWritabilityChanged(ChannelHandlerContext ctx)
Calls
fireChannelWritabilityChanged() to forward
to the next ChannelInboundHandler in the ChannelPipeline . |
void |
CombinedChannelDuplexHandler.channelWritabilityChanged(ChannelHandlerContext ctx) |
void |
DefaultChannelPipeline.TailContext.channelWritabilityChanged(ChannelHandlerContext ctx) |
void |
DefaultChannelPipeline.HeadContext.channelWritabilityChanged(ChannelHandlerContext ctx) |
void |
ChannelDuplexHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.close(ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
ChannelOutboundHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise)
Called once a close operation is made.
|
void |
ChannelOutboundHandlerAdapter.close(ChannelHandlerContext ctx,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.close(ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
CombinedChannelDuplexHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
DefaultChannelPipeline.HeadContext.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
ChannelDuplexHandler.connect(ChannelHandlerContext ctx,
java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.connect(SocketAddress, SocketAddress, ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
ChannelOutboundHandler.connect(ChannelHandlerContext ctx,
java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise)
Called once a connect operation is made.
|
void |
ChannelOutboundHandlerAdapter.connect(ChannelHandlerContext ctx,
java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.connect(SocketAddress, SocketAddress, ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
CombinedChannelDuplexHandler.connect(ChannelHandlerContext ctx,
java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
void |
DefaultChannelPipeline.HeadContext.connect(ChannelHandlerContext ctx,
java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
void |
ChannelDuplexHandler.deregister(ChannelHandlerContext ctx,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.close(ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
ChannelOutboundHandler.deregister(ChannelHandlerContext ctx,
ChannelPromise promise)
Called once a deregister operation is made from the current registered
EventLoop . |
void |
ChannelOutboundHandlerAdapter.deregister(ChannelHandlerContext ctx,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.deregister(ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
CombinedChannelDuplexHandler.deregister(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
DefaultChannelPipeline.HeadContext.deregister(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
ChannelDuplexHandler.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.disconnect(ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
ChannelOutboundHandler.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise)
Called once a disconnect operation is made.
|
void |
ChannelOutboundHandlerAdapter.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.disconnect(ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
CombinedChannelDuplexHandler.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
DefaultChannelPipeline.HeadContext.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
ChannelHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause)
Deprecated.
is part of
ChannelInboundHandler |
void |
ChannelHandlerAdapter.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause)
|
void |
ChannelInboundHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause)
Gets called if a
Throwable was thrown. |
void |
ChannelInboundHandlerAdapter.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause)
|
void |
ChannelInitializer.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause)
Handle the
Throwable by logging and closing the Channel . |
void |
CombinedChannelDuplexHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
void |
DefaultChannelPipeline.TailContext.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
void |
DefaultChannelPipeline.HeadContext.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
void |
ChannelDuplexHandler.flush(ChannelHandlerContext ctx)
|
void |
ChannelOutboundHandler.flush(ChannelHandlerContext ctx)
Called once a flush operation is made.
|
void |
ChannelOutboundHandlerAdapter.flush(ChannelHandlerContext ctx)
|
void |
CombinedChannelDuplexHandler.flush(ChannelHandlerContext ctx) |
void |
DefaultChannelPipeline.HeadContext.flush(ChannelHandlerContext ctx) |
void |
ChannelHandler.handlerAdded(ChannelHandlerContext ctx)
Gets called after the
ChannelHandler was added to the actual context and it's ready to handle events. |
void |
ChannelHandlerAdapter.handlerAdded(ChannelHandlerContext ctx)
Do nothing by default, sub-classes may override this method.
|
void |
ChannelInitializer.handlerAdded(ChannelHandlerContext ctx)
Do nothing by default, sub-classes may override this method.
|
void |
CombinedChannelDuplexHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
DefaultChannelPipeline.TailContext.handlerAdded(ChannelHandlerContext ctx) |
void |
DefaultChannelPipeline.HeadContext.handlerAdded(ChannelHandlerContext ctx) |
void |
ChannelHandler.handlerRemoved(ChannelHandlerContext ctx)
Gets called after the
ChannelHandler was removed from the actual context and it doesn't handle events
anymore. |
void |
ChannelHandlerAdapter.handlerRemoved(ChannelHandlerContext ctx)
Do nothing by default, sub-classes may override this method.
|
void |
CombinedChannelDuplexHandler.handlerRemoved(ChannelHandlerContext ctx) |
void |
DefaultChannelPipeline.TailContext.handlerRemoved(ChannelHandlerContext ctx) |
void |
DefaultChannelPipeline.HeadContext.handlerRemoved(ChannelHandlerContext ctx) |
private boolean |
ChannelInitializer.initChannel(ChannelHandlerContext ctx) |
void |
ChannelDuplexHandler.read(ChannelHandlerContext ctx)
|
void |
ChannelOutboundHandler.read(ChannelHandlerContext ctx)
Intercepts
read() . |
void |
ChannelOutboundHandlerAdapter.read(ChannelHandlerContext ctx)
|
void |
CombinedChannelDuplexHandler.read(ChannelHandlerContext ctx) |
void |
DefaultChannelPipeline.HeadContext.read(ChannelHandlerContext ctx) |
private void |
ChannelInitializer.remove(ChannelHandlerContext ctx) |
void |
ChannelInboundHandler.userEventTriggered(ChannelHandlerContext ctx,
java.lang.Object evt)
Gets called if an user event was triggered.
|
void |
ChannelInboundHandlerAdapter.userEventTriggered(ChannelHandlerContext ctx,
java.lang.Object evt)
Calls
fireUserEventTriggered(Object) to forward
to the next ChannelInboundHandler in the ChannelPipeline . |
void |
CombinedChannelDuplexHandler.userEventTriggered(ChannelHandlerContext ctx,
java.lang.Object evt) |
void |
DefaultChannelPipeline.TailContext.userEventTriggered(ChannelHandlerContext ctx,
java.lang.Object evt) |
void |
DefaultChannelPipeline.HeadContext.userEventTriggered(ChannelHandlerContext ctx,
java.lang.Object evt) |
void |
ChannelDuplexHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.write(Object, ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
ChannelOutboundHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise)
Called once a write operation is made.
|
void |
ChannelOutboundHandlerAdapter.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.write(Object, ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
CombinedChannelDuplexHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
void |
DefaultChannelPipeline.HeadContext.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
Constructor and Description |
---|
DelegatingChannelHandlerContext(ChannelHandlerContext ctx,
ChannelHandler handler) |
PendingWriteQueue(ChannelHandlerContext ctx) |
Modifier and Type | Field and Description |
---|---|
private ChannelHandlerContext |
MessageAggregator.ctx |
Modifier and Type | Method and Description |
---|---|
protected ChannelHandlerContext |
MessageAggregator.ctx() |
Modifier and Type | Method and Description |
---|---|
protected ByteBuf |
MessageToByteEncoder.allocateBuffer(ChannelHandlerContext ctx,
I msg,
boolean preferDirect)
Allocate a
ByteBuf which will be used as argument of #encode(ChannelHandlerContext, I, ByteBuf) . |
void |
DatagramPacketEncoder.bind(ChannelHandlerContext ctx,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
protected void |
ByteToMessageDecoder.callDecode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out)
Called once data should be decoded from the given
ByteBuf . |
protected void |
ReplayingDecoder.callDecode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
void |
DatagramPacketDecoder.channelActive(ChannelHandlerContext ctx) |
void |
ByteToMessageCodec.channelInactive(ChannelHandlerContext ctx) |
void |
ByteToMessageDecoder.channelInactive(ChannelHandlerContext ctx) |
void |
DatagramPacketDecoder.channelInactive(ChannelHandlerContext ctx) |
void |
MessageAggregator.channelInactive(ChannelHandlerContext ctx) |
private void |
ByteToMessageDecoder.channelInputClosed(ChannelHandlerContext ctx,
boolean callChannelInactive) |
(package private) void |
ByteToMessageDecoder.channelInputClosed(ChannelHandlerContext ctx,
java.util.List<java.lang.Object> out)
Called when the input of the channel was closed which may be because it changed to inactive or because of
ChannelInputShutdownEvent . |
(package private) void |
ReplayingDecoder.channelInputClosed(ChannelHandlerContext ctx,
java.util.List<java.lang.Object> out) |
void |
ByteToMessageCodec.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
ByteToMessageDecoder.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
MessageToMessageCodec.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
MessageToMessageDecoder.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
ByteToMessageCodec.channelReadComplete(ChannelHandlerContext ctx) |
void |
ByteToMessageDecoder.channelReadComplete(ChannelHandlerContext ctx) |
void |
DatagramPacketDecoder.channelReadComplete(ChannelHandlerContext ctx) |
void |
MessageAggregator.channelReadComplete(ChannelHandlerContext ctx) |
void |
DatagramPacketDecoder.channelRegistered(ChannelHandlerContext ctx) |
void |
DatagramPacketDecoder.channelUnregistered(ChannelHandlerContext ctx) |
void |
DatagramPacketDecoder.channelWritabilityChanged(ChannelHandlerContext ctx) |
void |
DatagramPacketEncoder.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
DatagramPacketEncoder.connect(ChannelHandlerContext ctx,
java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
protected java.lang.Object |
DelimiterBasedFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf buffer)
Create a frame out of the
ByteBuf and return it. |
protected java.lang.Object |
FixedLengthFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in)
Create a frame out of the
ByteBuf and return it. |
protected java.lang.Object |
LengthFieldBasedFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in)
Create a frame out of the
ByteBuf and return it. |
protected java.lang.Object |
LineBasedFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf buffer)
Create a frame out of the
ByteBuf and return it. |
protected abstract void |
ByteToMessageCodec.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected abstract void |
ByteToMessageDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out)
Decode the from one
ByteBuf to an other. |
protected void |
DelimiterBasedFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
FixedLengthFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
LengthFieldBasedFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
LineBasedFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
DatagramPacketDecoder.decode(ChannelHandlerContext ctx,
DatagramPacket msg,
java.util.List<java.lang.Object> out) |
protected void |
MessageAggregator.decode(ChannelHandlerContext ctx,
I msg,
java.util.List<java.lang.Object> out) |
protected abstract void |
MessageToMessageDecoder.decode(ChannelHandlerContext ctx,
I msg,
java.util.List<java.lang.Object> out)
Decode from one message to an other.
|
protected abstract void |
MessageToMessageCodec.decode(ChannelHandlerContext ctx,
INBOUND_IN msg,
java.util.List<java.lang.Object> out) |
protected void |
ByteToMessageCodec.decodeLast(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
ByteToMessageDecoder.decodeLast(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out)
Is called one last time when the
ChannelHandlerContext goes in-active. |
(package private) void |
ByteToMessageDecoder.decodeRemovalReentryProtection(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out)
Decode the from one
ByteBuf to an other. |
void |
DatagramPacketEncoder.deregister(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
DatagramPacketEncoder.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise) |
protected void |
DatagramPacketEncoder.encode(ChannelHandlerContext ctx,
AddressedEnvelope<M,java.net.InetSocketAddress> msg,
java.util.List<java.lang.Object> out) |
protected void |
LengthFieldPrepender.encode(ChannelHandlerContext ctx,
ByteBuf msg,
java.util.List<java.lang.Object> out) |
protected abstract void |
ByteToMessageCodec.encode(ChannelHandlerContext ctx,
I msg,
ByteBuf out) |
protected void |
ByteToMessageCodec.Encoder.encode(ChannelHandlerContext ctx,
I msg,
ByteBuf out) |
protected abstract void |
MessageToByteEncoder.encode(ChannelHandlerContext ctx,
I msg,
ByteBuf out)
Encode a message into a
ByteBuf . |
protected abstract void |
MessageToMessageEncoder.encode(ChannelHandlerContext ctx,
I msg,
java.util.List<java.lang.Object> out)
Encode from one message to an other.
|
protected abstract void |
MessageToMessageCodec.encode(ChannelHandlerContext ctx,
OUTBOUND_IN msg,
java.util.List<java.lang.Object> out) |
void |
DatagramPacketDecoder.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
void |
DatagramPacketEncoder.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
protected ByteBuf |
LengthFieldBasedFrameDecoder.extractFrame(ChannelHandlerContext ctx,
ByteBuf buffer,
int index,
int length)
Extract the sub-region of the specified buffer.
|
private void |
LineBasedFrameDecoder.fail(ChannelHandlerContext ctx,
int length) |
private void |
LineBasedFrameDecoder.fail(ChannelHandlerContext ctx,
java.lang.String length) |
(package private) static void |
ByteToMessageDecoder.fireChannelRead(ChannelHandlerContext ctx,
CodecOutputList msgs,
int numElements)
Get
numElements out of the CodecOutputList and forward these through the pipeline. |
(package private) static void |
ByteToMessageDecoder.fireChannelRead(ChannelHandlerContext ctx,
java.util.List<java.lang.Object> msgs,
int numElements)
Get
numElements out of the List and forward these through the pipeline. |
void |
DatagramPacketEncoder.flush(ChannelHandlerContext ctx) |
protected void |
MessageAggregator.handleOversizedMessage(ChannelHandlerContext ctx,
S oversized)
Invoked when an incoming request exceeds the maximum content length.
|
void |
ByteToMessageCodec.handlerAdded(ChannelHandlerContext ctx) |
void |
DatagramPacketDecoder.handlerAdded(ChannelHandlerContext ctx) |
void |
DatagramPacketEncoder.handlerAdded(ChannelHandlerContext ctx) |
void |
MessageAggregator.handlerAdded(ChannelHandlerContext ctx) |
void |
ByteToMessageCodec.handlerRemoved(ChannelHandlerContext ctx) |
void |
ByteToMessageDecoder.handlerRemoved(ChannelHandlerContext ctx) |
void |
DatagramPacketDecoder.handlerRemoved(ChannelHandlerContext ctx) |
void |
DatagramPacketEncoder.handlerRemoved(ChannelHandlerContext ctx) |
void |
MessageAggregator.handlerRemoved(ChannelHandlerContext ctx) |
protected void |
ByteToMessageDecoder.handlerRemoved0(ChannelHandlerContext ctx)
Gets called after the
ByteToMessageDecoder was removed from the actual context and it doesn't handle
events anymore. |
private void |
MessageAggregator.invokeHandleOversizedMessage(ChannelHandlerContext ctx,
S oversized) |
void |
DatagramPacketEncoder.read(ChannelHandlerContext ctx) |
void |
ByteToMessageDecoder.userEventTriggered(ChannelHandlerContext ctx,
java.lang.Object evt) |
void |
DatagramPacketDecoder.userEventTriggered(ChannelHandlerContext ctx,
java.lang.Object evt) |
void |
ByteToMessageCodec.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
void |
MessageToByteEncoder.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
void |
MessageToMessageCodec.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
void |
MessageToMessageEncoder.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
protected void |
Base64Decoder.decode(ChannelHandlerContext ctx,
ByteBuf msg,
java.util.List<java.lang.Object> out) |
protected void |
Base64Encoder.encode(ChannelHandlerContext ctx,
ByteBuf msg,
java.util.List<java.lang.Object> out) |
Modifier and Type | Method and Description |
---|---|
protected void |
ByteArrayDecoder.decode(ChannelHandlerContext ctx,
ByteBuf msg,
java.util.List<java.lang.Object> out) |
protected void |
ByteArrayEncoder.encode(ChannelHandlerContext ctx,
byte[] msg,
java.util.List<java.lang.Object> out) |
Modifier and Type | Field and Description |
---|---|
private ChannelHandlerContext |
Bzip2Encoder.ctx
Used to interact with its
ChannelPipeline and other handlers. |
private ChannelHandlerContext |
JZlibEncoder.ctx |
private ChannelHandlerContext |
JdkZlibEncoder.ctx |
Modifier and Type | Method and Description |
---|---|
private ChannelHandlerContext |
Bzip2Encoder.ctx() |
private ChannelHandlerContext |
JZlibEncoder.ctx() |
private ChannelHandlerContext |
JdkZlibEncoder.ctx() |
Modifier and Type | Method and Description |
---|---|
protected ByteBuf |
JdkZlibEncoder.allocateBuffer(ChannelHandlerContext ctx,
ByteBuf msg,
boolean preferDirect) |
void |
Bzip2Encoder.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
JZlibEncoder.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
JdkZlibEncoder.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
protected void |
Bzip2Decoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
FastLzFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
JZlibDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
JdkZlibDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
SnappyFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
Bzip2Encoder.encode(ChannelHandlerContext ctx,
ByteBuf in,
ByteBuf out) |
protected void |
FastLzFrameEncoder.encode(ChannelHandlerContext ctx,
ByteBuf in,
ByteBuf out) |
protected void |
JZlibEncoder.encode(ChannelHandlerContext ctx,
ByteBuf in,
ByteBuf out) |
protected void |
JdkZlibEncoder.encode(ChannelHandlerContext ctx,
ByteBuf uncompressed,
ByteBuf out) |
protected void |
SnappyFrameEncoder.encode(ChannelHandlerContext ctx,
ByteBuf in,
ByteBuf out) |
private ChannelFuture |
Bzip2Encoder.finishEncode(ChannelHandlerContext ctx,
ChannelPromise promise) |
private ChannelFuture |
JZlibEncoder.finishEncode(ChannelHandlerContext ctx,
ChannelPromise promise) |
private ChannelFuture |
JdkZlibEncoder.finishEncode(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
Bzip2Encoder.handlerAdded(ChannelHandlerContext ctx) |
void |
JZlibEncoder.handlerAdded(ChannelHandlerContext ctx) |
void |
JdkZlibEncoder.handlerAdded(ChannelHandlerContext ctx) |
protected void |
JdkZlibDecoder.handlerRemoved0(ChannelHandlerContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected ByteBuf |
DatagramDnsQueryEncoder.allocateBuffer(ChannelHandlerContext ctx,
AddressedEnvelope<DnsQuery,java.net.InetSocketAddress> msg)
Allocate a
ByteBuf which will be used for constructing a datagram packet. |
protected ByteBuf |
DatagramDnsResponseEncoder.allocateBuffer(ChannelHandlerContext ctx,
AddressedEnvelope<DnsResponse,java.net.InetSocketAddress> msg)
Allocate a
ByteBuf which will be used for constructing a datagram packet. |
protected void |
DatagramDnsQueryDecoder.decode(ChannelHandlerContext ctx,
DatagramPacket packet,
java.util.List<java.lang.Object> out) |
protected void |
DatagramDnsResponseDecoder.decode(ChannelHandlerContext ctx,
DatagramPacket packet,
java.util.List<java.lang.Object> out) |
protected void |
DatagramDnsQueryEncoder.encode(ChannelHandlerContext ctx,
AddressedEnvelope<DnsQuery,java.net.InetSocketAddress> in,
java.util.List<java.lang.Object> out) |
protected void |
DatagramDnsResponseEncoder.encode(ChannelHandlerContext ctx,
AddressedEnvelope<DnsResponse,java.net.InetSocketAddress> in,
java.util.List<java.lang.Object> out) |
Modifier and Type | Method and Description |
---|---|
void |
HAProxyMessageDecoder.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
protected void |
HAProxyMessageDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
private ByteBuf |
HAProxyMessageDecoder.decodeLine(ChannelHandlerContext ctx,
ByteBuf buffer)
Create a frame out of the
ByteBuf and return it. |
private ByteBuf |
HAProxyMessageDecoder.decodeStruct(ChannelHandlerContext ctx,
ByteBuf buffer)
Create a frame out of the
ByteBuf and return it. |
private void |
HAProxyMessageDecoder.fail(ChannelHandlerContext ctx,
java.lang.String errMsg,
java.lang.Throwable t) |
private void |
HAProxyMessageDecoder.failOverLimit(ChannelHandlerContext ctx,
int length) |
private void |
HAProxyMessageDecoder.failOverLimit(ChannelHandlerContext ctx,
java.lang.String length) |
Modifier and Type | Method and Description |
---|---|
protected void |
JsonObjectDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected ByteBuf |
JsonObjectDecoder.extractObject(ChannelHandlerContext ctx,
ByteBuf buffer,
int index,
int length)
Override this method if you want to filter the json objects/arrays that get passed through the pipeline.
|
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractMemcacheObjectEncoder.encode(ChannelHandlerContext ctx,
java.lang.Object msg,
java.util.List<java.lang.Object> out) |
protected abstract ByteBuf |
AbstractMemcacheObjectEncoder.encodeMessage(ChannelHandlerContext ctx,
M msg)
Take the given
MemcacheMessage and encode it into a writable ByteBuf . |
Modifier and Type | Method and Description |
---|---|
void |
AbstractBinaryMemcacheDecoder.channelInactive(ChannelHandlerContext ctx)
When the channel goes inactive, release all frames to prevent data leaks.
|
void |
BinaryMemcacheClientCodec.Decoder.channelInactive(ChannelHandlerContext ctx) |
protected void |
AbstractBinaryMemcacheDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
BinaryMemcacheClientCodec.Decoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
BinaryMemcacheClientCodec.Encoder.encode(ChannelHandlerContext ctx,
java.lang.Object msg,
java.util.List<java.lang.Object> out) |
protected ByteBuf |
AbstractBinaryMemcacheEncoder.encodeMessage(ChannelHandlerContext ctx,
M msg) |
Modifier and Type | Method and Description |
---|---|
protected void |
MqttDecoder.decode(ChannelHandlerContext ctx,
ByteBuf buffer,
java.util.List<java.lang.Object> out) |
protected void |
MqttEncoder.encode(ChannelHandlerContext ctx,
MqttMessage msg,
java.util.List<java.lang.Object> out) |
Modifier and Type | Method and Description |
---|---|
protected void |
RedisDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
RedisArrayAggregator.decode(ChannelHandlerContext ctx,
RedisMessage msg,
java.util.List<java.lang.Object> out) |
protected void |
RedisEncoder.encode(ChannelHandlerContext ctx,
RedisMessage msg,
java.util.List<java.lang.Object> out) |
Modifier and Type | Method and Description |
---|---|
protected void |
SctpInboundByteStreamHandler.decode(ChannelHandlerContext ctx,
SctpMessage msg,
java.util.List<java.lang.Object> out) |
protected void |
SctpMessageCompletionHandler.decode(ChannelHandlerContext ctx,
SctpMessage msg,
java.util.List<java.lang.Object> out) |
protected void |
SctpOutboundByteStreamHandler.encode(ChannelHandlerContext ctx,
ByteBuf msg,
java.util.List<java.lang.Object> out) |
Modifier and Type | Method and Description |
---|---|
protected java.lang.Object |
ObjectDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in) |
protected void |
CompatibleObjectEncoder.encode(ChannelHandlerContext ctx,
java.io.Serializable msg,
ByteBuf out) |
protected void |
ObjectEncoder.encode(ChannelHandlerContext ctx,
java.io.Serializable msg,
ByteBuf out) |
Modifier and Type | Method and Description |
---|---|
protected SmtpResponse |
SmtpResponseDecoder.decode(ChannelHandlerContext ctx,
ByteBuf buffer) |
protected void |
SmtpRequestEncoder.encode(ChannelHandlerContext ctx,
java.lang.Object msg,
java.util.List<java.lang.Object> out) |
Modifier and Type | Method and Description |
---|---|
protected void |
SocksAuthRequestDecoder.decode(ChannelHandlerContext ctx,
ByteBuf byteBuf,
java.util.List<java.lang.Object> out) |
protected void |
SocksAuthResponseDecoder.decode(ChannelHandlerContext channelHandlerContext,
ByteBuf byteBuf,
java.util.List<java.lang.Object> out) |
protected void |
SocksCmdRequestDecoder.decode(ChannelHandlerContext ctx,
ByteBuf byteBuf,
java.util.List<java.lang.Object> out) |
protected void |
SocksCmdResponseDecoder.decode(ChannelHandlerContext ctx,
ByteBuf byteBuf,
java.util.List<java.lang.Object> out) |
protected void |
SocksInitRequestDecoder.decode(ChannelHandlerContext ctx,
ByteBuf byteBuf,
java.util.List<java.lang.Object> out) |
protected void |
SocksInitResponseDecoder.decode(ChannelHandlerContext ctx,
ByteBuf byteBuf,
java.util.List<java.lang.Object> out) |
protected void |
SocksMessageEncoder.encode(ChannelHandlerContext ctx,
SocksMessage msg,
ByteBuf out) |
Modifier and Type | Method and Description |
---|---|
protected void |
SocksPortUnificationServerHandler.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
private static void |
SocksPortUnificationServerHandler.logKnownVersion(ChannelHandlerContext ctx,
SocksVersion version) |
private static void |
SocksPortUnificationServerHandler.logUnknownVersion(ChannelHandlerContext ctx,
byte versionVal) |
Modifier and Type | Method and Description |
---|---|
protected void |
Socks4ClientDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
Socks4ServerDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
Socks4ClientEncoder.encode(ChannelHandlerContext ctx,
Socks4CommandRequest msg,
ByteBuf out) |
protected void |
Socks4ServerEncoder.encode(ChannelHandlerContext ctx,
Socks4CommandResponse msg,
ByteBuf out) |
Modifier and Type | Method and Description |
---|---|
protected void |
Socks5CommandRequestDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
Socks5CommandResponseDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
Socks5InitialRequestDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
Socks5InitialResponseDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
Socks5PasswordAuthRequestDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
Socks5PasswordAuthResponseDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
Socks5ClientEncoder.encode(ChannelHandlerContext ctx,
Socks5Message msg,
ByteBuf out) |
protected void |
Socks5ServerEncoder.encode(ChannelHandlerContext ctx,
Socks5Message msg,
ByteBuf out) |
Modifier and Type | Method and Description |
---|---|
protected void |
StompSubframeDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
StompSubframeEncoder.encode(ChannelHandlerContext ctx,
StompSubframe msg,
java.util.List<java.lang.Object> out) |
private static ByteBuf |
StompSubframeEncoder.encodeContent(StompContentSubframe content,
ChannelHandlerContext ctx) |
private static ByteBuf |
StompSubframeEncoder.encodeFrame(StompHeadersSubframe frame,
ChannelHandlerContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected void |
StringDecoder.decode(ChannelHandlerContext ctx,
ByteBuf msg,
java.util.List<java.lang.Object> out) |
protected void |
LineEncoder.encode(ChannelHandlerContext ctx,
java.lang.CharSequence msg,
java.util.List<java.lang.Object> out) |
protected void |
StringEncoder.encode(ChannelHandlerContext ctx,
java.lang.CharSequence msg,
java.util.List<java.lang.Object> out) |
Modifier and Type | Method and Description |
---|---|
protected void |
XmlFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
private static void |
XmlFrameDecoder.fail(ChannelHandlerContext ctx) |
Modifier and Type | Method and Description |
---|---|
void |
FlowControlHandler.channelInactive(ChannelHandlerContext ctx) |
void |
FlowControlHandler.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
FlowControlHandler.channelReadComplete(ChannelHandlerContext ctx) |
private int |
FlowControlHandler.dequeue(ChannelHandlerContext ctx,
int minConsume)
Dequeues one or many (or none) messages depending on the channel's auto
reading state and returns the number of messages that were consumed from
the internal queue.
|
void |
FlowControlHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
FlowControlHandler.read(ChannelHandlerContext ctx) |
Modifier and Type | Field and Description |
---|---|
private ChannelHandlerContext |
FlushConsolidationHandler.ctx |
Modifier and Type | Method and Description |
---|---|
void |
FlushConsolidationHandler.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
FlushConsolidationHandler.channelReadComplete(ChannelHandlerContext ctx) |
void |
FlushConsolidationHandler.channelWritabilityChanged(ChannelHandlerContext ctx) |
void |
FlushConsolidationHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
FlushConsolidationHandler.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
FlushConsolidationHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
void |
FlushConsolidationHandler.flush(ChannelHandlerContext ctx) |
private void |
FlushConsolidationHandler.flushIfNeeded(ChannelHandlerContext ctx) |
private void |
FlushConsolidationHandler.flushNow(ChannelHandlerContext ctx) |
void |
FlushConsolidationHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
FlushConsolidationHandler.handlerRemoved(ChannelHandlerContext ctx) |
private void |
FlushConsolidationHandler.resetReadAndFlushIfNeeded(ChannelHandlerContext ctx) |
private void |
FlushConsolidationHandler.scheduleFlush(ChannelHandlerContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
RuleBasedIpFilter.accept(ChannelHandlerContext ctx,
java.net.InetSocketAddress remoteAddress) |
protected boolean |
UniqueIpFilter.accept(ChannelHandlerContext ctx,
java.net.InetSocketAddress remoteAddress) |
protected abstract boolean |
AbstractRemoteAddressFilter.accept(ChannelHandlerContext ctx,
T remoteAddress)
This method is called immediately after a
Channel gets registered. |
protected void |
AbstractRemoteAddressFilter.channelAccepted(ChannelHandlerContext ctx,
T remoteAddress)
This method is called if
remoteAddress gets accepted by
AbstractRemoteAddressFilter.accept(ChannelHandlerContext, SocketAddress) . |
void |
AbstractRemoteAddressFilter.channelActive(ChannelHandlerContext ctx) |
void |
AbstractRemoteAddressFilter.channelRegistered(ChannelHandlerContext ctx) |
protected ChannelFuture |
AbstractRemoteAddressFilter.channelRejected(ChannelHandlerContext ctx,
T remoteAddress)
This method is called if
remoteAddress gets rejected by
AbstractRemoteAddressFilter.accept(ChannelHandlerContext, SocketAddress) . |
private boolean |
AbstractRemoteAddressFilter.handleNewChannel(ChannelHandlerContext ctx) |
Modifier and Type | Method and Description |
---|---|
void |
LoggingHandler.bind(ChannelHandlerContext ctx,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
void |
LoggingHandler.channelActive(ChannelHandlerContext ctx) |
void |
LoggingHandler.channelInactive(ChannelHandlerContext ctx) |
void |
LoggingHandler.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
LoggingHandler.channelReadComplete(ChannelHandlerContext ctx) |
void |
LoggingHandler.channelRegistered(ChannelHandlerContext ctx) |
void |
LoggingHandler.channelUnregistered(ChannelHandlerContext ctx) |
void |
LoggingHandler.channelWritabilityChanged(ChannelHandlerContext ctx) |
void |
LoggingHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
LoggingHandler.connect(ChannelHandlerContext ctx,
java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
void |
LoggingHandler.deregister(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
LoggingHandler.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
LoggingHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
void |
LoggingHandler.flush(ChannelHandlerContext ctx) |
protected java.lang.String |
LoggingHandler.format(ChannelHandlerContext ctx,
java.lang.String eventName)
Formats an event and returns the formatted message.
|
protected java.lang.String |
LoggingHandler.format(ChannelHandlerContext ctx,
java.lang.String eventName,
java.lang.Object arg)
Formats an event and returns the formatted message.
|
protected java.lang.String |
LoggingHandler.format(ChannelHandlerContext ctx,
java.lang.String eventName,
java.lang.Object firstArg,
java.lang.Object secondArg)
Formats an event and returns the formatted message.
|
private static java.lang.String |
LoggingHandler.formatByteBuf(ChannelHandlerContext ctx,
java.lang.String eventName,
ByteBuf msg)
Generates the default log message of the specified event whose argument is a
ByteBuf . |
private static java.lang.String |
LoggingHandler.formatByteBufHolder(ChannelHandlerContext ctx,
java.lang.String eventName,
ByteBufHolder msg)
Generates the default log message of the specified event whose argument is a
ByteBufHolder . |
private static java.lang.String |
LoggingHandler.formatSimple(ChannelHandlerContext ctx,
java.lang.String eventName,
java.lang.Object msg)
Generates the default log message of the specified event whose argument is an arbitrary object.
|
void |
LoggingHandler.userEventTriggered(ChannelHandlerContext ctx,
java.lang.Object evt) |
void |
LoggingHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
Modifier and Type | Field and Description |
---|---|
private ChannelHandlerContext |
SslHandler.ctx |
Modifier and Type | Method and Description |
---|---|
private ByteBuf |
SslHandler.allocate(ChannelHandlerContext ctx,
int capacity)
Always prefer a direct buffer when it's pooled, so that we reduce the number of memory copies
in
OpenSslEngine . |
private ByteBuf |
SslHandler.allocateOutNetBuf(ChannelHandlerContext ctx,
int pendingBytes,
int numComponents)
Allocates an outbound network buffer for
SSLEngine.wrap(ByteBuffer, ByteBuffer) which can encrypt
the specified amount of pending bytes. |
void |
AbstractSniHandler.bind(ChannelHandlerContext ctx,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
void |
SslHandler.bind(ChannelHandlerContext ctx,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
void |
SslHandler.channelActive(ChannelHandlerContext ctx)
Issues an initial TLS handshake once connected when used in client-mode
|
void |
SslHandler.channelInactive(ChannelHandlerContext ctx) |
void |
SslHandler.channelReadComplete(ChannelHandlerContext ctx) |
void |
AbstractSniHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
SslHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
private void |
SslHandler.closeOutboundAndChannel(ChannelHandlerContext ctx,
ChannelPromise promise,
boolean disconnect) |
protected abstract void |
ApplicationProtocolNegotiationHandler.configurePipeline(ChannelHandlerContext ctx,
java.lang.String protocol)
Invoked on successful initial SSL/TLS handshake.
|
void |
AbstractSniHandler.connect(ChannelHandlerContext ctx,
java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
void |
SslHandler.connect(ChannelHandlerContext ctx,
java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
protected void |
AbstractSniHandler.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
OptionalSslHandler.decode(ChannelHandlerContext context,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
SslHandler.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
void |
AbstractSniHandler.deregister(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
SslHandler.deregister(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
AbstractSniHandler.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
SslHandler.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
ApplicationProtocolNegotiationHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
void |
SslHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
private void |
SslHandler.finishWrap(ChannelHandlerContext ctx,
ByteBuf out,
ChannelPromise promise,
boolean inUnwrap,
boolean needUnwrap) |
void |
AbstractSniHandler.flush(ChannelHandlerContext ctx) |
void |
SslHandler.flush(ChannelHandlerContext ctx) |
private void |
SslHandler.flush(ChannelHandlerContext ctx,
ChannelPromise promise) |
private void |
SslHandler.flushIfNeeded(ChannelHandlerContext ctx) |
private void |
SslHandler.forceFlush(ChannelHandlerContext ctx) |
private void |
OptionalSslHandler.handleNonSsl(ChannelHandlerContext context) |
void |
SslHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
SslHandler.handlerRemoved0(ChannelHandlerContext ctx) |
private void |
OptionalSslHandler.handleSsl(ChannelHandlerContext context) |
protected void |
ApplicationProtocolNegotiationHandler.handshakeFailure(ChannelHandlerContext ctx,
java.lang.Throwable cause)
Invoked on failed initial SSL/TLS handshake.
|
protected abstract Future<T> |
AbstractSniHandler.lookup(ChannelHandlerContext ctx,
java.lang.String hostname)
Kicks off a lookup for the given SNI value and returns a
Future which in turn will
notify the AbstractSniHandler.onLookupComplete(ChannelHandlerContext, String, Future) on completion. |
protected Future<SslContext> |
SniHandler.lookup(ChannelHandlerContext ctx,
java.lang.String hostname)
The default implementation will simply call
AsyncMapping.map(Object, Promise) but
users can override this method to implement custom behavior. |
protected ChannelHandler |
OptionalSslHandler.newNonSslHandler(ChannelHandlerContext context)
Override to configure the ChannelHandler.
|
protected SslHandler |
OptionalSslHandler.newSslHandler(ChannelHandlerContext context,
SslContext sslContext)
Override to configure the SslHandler eg.
|
(package private) static void |
SslUtils.notifyHandshakeFailure(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
protected void |
SniHandler.onLookupComplete(ChannelHandlerContext ctx,
java.lang.String hostname,
Future<SslContext> future) |
protected abstract void |
AbstractSniHandler.onLookupComplete(ChannelHandlerContext ctx,
java.lang.String hostname,
Future<T> future)
Called upon completion of the
AbstractSniHandler.lookup(ChannelHandlerContext, String) Future . |
void |
AbstractSniHandler.read(ChannelHandlerContext ctx) |
void |
SslHandler.read(ChannelHandlerContext ctx) |
private void |
SslHandler.readIfNeeded(ChannelHandlerContext ctx) |
protected void |
SniHandler.replaceHandler(ChannelHandlerContext ctx,
java.lang.String hostname,
SslContext sslContext)
The default implementation of this method will simply replace
this SniHandler
instance with a SslHandler . |
private void |
SslHandler.safeClose(ChannelHandlerContext ctx,
ChannelFuture flushFuture,
ChannelPromise promise) |
private void |
AbstractSniHandler.select(ChannelHandlerContext ctx,
java.lang.String hostname) |
private void |
SslHandler.setHandshakeFailure(ChannelHandlerContext ctx,
java.lang.Throwable cause)
Notify all the handshake futures about the failure during the handshake.
|
private void |
SslHandler.setHandshakeFailure(ChannelHandlerContext ctx,
java.lang.Throwable cause,
boolean closeInbound)
Notify all the handshake futures about the failure during the handshake.
|
private boolean |
SslHandler.unwrap(ChannelHandlerContext ctx,
ByteBuf packet,
int offset,
int length)
Unwraps inbound SSL records.
|
private void |
SslHandler.unwrapNonAppData(ChannelHandlerContext ctx)
Calls
SSLEngine.unwrap(ByteBuffer, ByteBuffer) with an empty buffer to handle handshakes, etc. |
void |
ApplicationProtocolNegotiationHandler.userEventTriggered(ChannelHandlerContext ctx,
java.lang.Object evt) |
private void |
SslHandler.wrap(ChannelHandlerContext ctx,
boolean inUnwrap) |
private void |
SslHandler.wrapAndFlush(ChannelHandlerContext ctx) |
private void |
SslHandler.wrapNonAppData(ChannelHandlerContext ctx,
boolean inUnwrap)
|
void |
AbstractSniHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
void |
SslHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
Modifier and Type | Field and Description |
---|---|
private ChannelHandlerContext |
ChunkedWriteHandler.ctx |
Modifier and Type | Method and Description |
---|---|
void |
ChunkedWriteHandler.channelInactive(ChannelHandlerContext ctx) |
void |
ChunkedWriteHandler.channelWritabilityChanged(ChannelHandlerContext ctx) |
private void |
ChunkedWriteHandler.doFlush(ChannelHandlerContext ctx) |
void |
ChunkedWriteHandler.flush(ChannelHandlerContext ctx) |
void |
ChunkedWriteHandler.handlerAdded(ChannelHandlerContext ctx) |
ByteBuf |
ChunkedFile.readChunk(ChannelHandlerContext ctx)
Deprecated.
|
B |
ChunkedInput.readChunk(ChannelHandlerContext ctx)
Deprecated.
Use
ChunkedInput.readChunk(ByteBufAllocator) .
Fetches a chunked data from the stream. Once this method returns the last chunk
and thus the stream has reached at its end, any subsequent |
ByteBuf |
ChunkedNioFile.readChunk(ChannelHandlerContext ctx)
Deprecated.
|
ByteBuf |
ChunkedNioStream.readChunk(ChannelHandlerContext ctx)
Deprecated.
|
ByteBuf |
ChunkedStream.readChunk(ChannelHandlerContext ctx)
Deprecated.
|
void |
ChunkedWriteHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
Modifier and Type | Field and Description |
---|---|
private ChannelHandlerContext |
IdleStateHandler.AbstractIdleTask.ctx |
private ChannelHandlerContext |
WriteTimeoutHandler.WriteTimeoutTask.ctx |
Modifier and Type | Method and Description |
---|---|
void |
IdleStateHandler.channelActive(ChannelHandlerContext ctx) |
protected void |
IdleStateHandler.channelIdle(ChannelHandlerContext ctx,
IdleStateEvent evt)
Is called when an
IdleStateEvent should be fired. |
protected void |
ReadTimeoutHandler.channelIdle(ChannelHandlerContext ctx,
IdleStateEvent evt) |
void |
IdleStateHandler.channelInactive(ChannelHandlerContext ctx) |
void |
IdleStateHandler.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
IdleStateHandler.channelReadComplete(ChannelHandlerContext ctx) |
void |
IdleStateHandler.channelRegistered(ChannelHandlerContext ctx) |
void |
IdleStateHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
IdleStateHandler.handlerRemoved(ChannelHandlerContext ctx) |
void |
WriteTimeoutHandler.handlerRemoved(ChannelHandlerContext ctx) |
private boolean |
IdleStateHandler.hasOutputChanged(ChannelHandlerContext ctx,
boolean first)
Returns
true if and only if the IdleStateHandler was constructed
with IdleStateHandler.observeOutput enabled and there has been an observed change in the
ChannelOutboundBuffer between two consecutive calls of this method. |
private void |
IdleStateHandler.initialize(ChannelHandlerContext ctx) |
private void |
IdleStateHandler.initOutputChanged(ChannelHandlerContext ctx) |
protected void |
ReadTimeoutHandler.readTimedOut(ChannelHandlerContext ctx)
Is called when a read timeout was detected.
|
protected abstract void |
IdleStateHandler.AbstractIdleTask.run(ChannelHandlerContext ctx) |
protected void |
IdleStateHandler.ReaderIdleTimeoutTask.run(ChannelHandlerContext ctx) |
protected void |
IdleStateHandler.WriterIdleTimeoutTask.run(ChannelHandlerContext ctx) |
protected void |
IdleStateHandler.AllIdleTimeoutTask.run(ChannelHandlerContext ctx) |
(package private) java.util.concurrent.ScheduledFuture<?> |
IdleStateHandler.schedule(ChannelHandlerContext ctx,
java.lang.Runnable task,
long delay,
java.util.concurrent.TimeUnit unit)
This method is visible for testing!
|
private void |
WriteTimeoutHandler.scheduleTimeout(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
IdleStateHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
void |
WriteTimeoutHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
protected void |
WriteTimeoutHandler.writeTimedOut(ChannelHandlerContext ctx)
Is called when a write timeout was detected
|
Constructor and Description |
---|
AbstractIdleTask(ChannelHandlerContext ctx) |
AllIdleTimeoutTask(ChannelHandlerContext ctx) |
ReaderIdleTimeoutTask(ChannelHandlerContext ctx) |
WriterIdleTimeoutTask(ChannelHandlerContext ctx) |
WriteTimeoutTask(ChannelHandlerContext ctx,
ChannelPromise promise) |
Modifier and Type | Field and Description |
---|---|
(package private) ChannelHandlerContext |
AbstractTrafficShapingHandler.ReopenReadTimerTask.ctx |
Modifier and Type | Method and Description |
---|---|
void |
AbstractTrafficShapingHandler.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
GlobalChannelTrafficShapingHandler.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
AbstractTrafficShapingHandler.channelRegistered(ChannelHandlerContext ctx) |
(package private) long |
AbstractTrafficShapingHandler.checkWaitReadTime(ChannelHandlerContext ctx,
long wait,
long now)
Method overridden in GTSH to take into account specific timer for the channel.
|
protected long |
GlobalChannelTrafficShapingHandler.checkWaitReadTime(ChannelHandlerContext ctx,
long wait,
long now) |
(package private) long |
GlobalTrafficShapingHandler.checkWaitReadTime(ChannelHandlerContext ctx,
long wait,
long now) |
(package private) void |
AbstractTrafficShapingHandler.checkWriteSuspend(ChannelHandlerContext ctx,
long delay,
long queueSize)
Check the writability according to delay and size for the channel.
|
private GlobalChannelTrafficShapingHandler.PerChannel |
GlobalChannelTrafficShapingHandler.getOrSetPerChannel(ChannelHandlerContext ctx) |
private GlobalTrafficShapingHandler.PerChannel |
GlobalTrafficShapingHandler.getOrSetPerChannel(ChannelHandlerContext ctx) |
void |
ChannelTrafficShapingHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
GlobalChannelTrafficShapingHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
GlobalTrafficShapingHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
ChannelTrafficShapingHandler.handlerRemoved(ChannelHandlerContext ctx) |
void |
GlobalChannelTrafficShapingHandler.handlerRemoved(ChannelHandlerContext ctx) |
void |
GlobalTrafficShapingHandler.handlerRemoved(ChannelHandlerContext ctx) |
(package private) void |
AbstractTrafficShapingHandler.informReadOperation(ChannelHandlerContext ctx,
long now)
Method overridden in GTSH to take into account specific timer for the channel.
|
protected void |
GlobalChannelTrafficShapingHandler.informReadOperation(ChannelHandlerContext ctx,
long now) |
(package private) void |
GlobalTrafficShapingHandler.informReadOperation(ChannelHandlerContext ctx,
long now) |
protected static boolean |
AbstractTrafficShapingHandler.isHandlerActive(ChannelHandlerContext ctx) |
void |
AbstractTrafficShapingHandler.read(ChannelHandlerContext ctx) |
(package private) void |
AbstractTrafficShapingHandler.releaseReadSuspended(ChannelHandlerContext ctx)
Release the Read suspension
|
(package private) void |
AbstractTrafficShapingHandler.releaseWriteSuspended(ChannelHandlerContext ctx)
Explicitly release the Write suspended status.
|
private void |
GlobalChannelTrafficShapingHandler.sendAllValid(ChannelHandlerContext ctx,
GlobalChannelTrafficShapingHandler.PerChannel perChannel,
long now) |
private void |
GlobalTrafficShapingHandler.sendAllValid(ChannelHandlerContext ctx,
GlobalTrafficShapingHandler.PerChannel perChannel,
long now) |
private void |
ChannelTrafficShapingHandler.sendAllValid(ChannelHandlerContext ctx,
long now) |
(package private) void |
AbstractTrafficShapingHandler.setUserDefinedWritability(ChannelHandlerContext ctx,
boolean writable) |
protected void |
AbstractTrafficShapingHandler.submitWrite(ChannelHandlerContext ctx,
java.lang.Object msg,
long delay,
ChannelPromise promise)
Deprecated.
|
(package private) abstract void |
AbstractTrafficShapingHandler.submitWrite(ChannelHandlerContext ctx,
java.lang.Object msg,
long size,
long delay,
long now,
ChannelPromise promise) |
(package private) void |
ChannelTrafficShapingHandler.submitWrite(ChannelHandlerContext ctx,
java.lang.Object msg,
long size,
long delay,
long now,
ChannelPromise promise) |
protected void |
GlobalChannelTrafficShapingHandler.submitWrite(ChannelHandlerContext ctx,
java.lang.Object msg,
long size,
long writedelay,
long now,
ChannelPromise promise) |
(package private) void |
GlobalTrafficShapingHandler.submitWrite(ChannelHandlerContext ctx,
java.lang.Object msg,
long size,
long writedelay,
long now,
ChannelPromise promise) |
void |
AbstractTrafficShapingHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
void |
GlobalChannelTrafficShapingHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
Constructor and Description |
---|
ReopenReadTimerTask(ChannelHandlerContext ctx) |
Modifier and Type | Method and Description |
---|---|
void |
DnsNameResolver.DnsResponseHandler.channelActive(ChannelHandlerContext ctx) |
void |
DnsNameResolver.DnsResponseHandler.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
DnsNameResolver.DnsResponseHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |