Package | Description |
---|---|
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.haproxy |
Decodes an HAProxy proxy protocol header
|
io.netty.handler.codec.http |
Encoder, decoder and their related message types for HTTP.
|
io.netty.handler.codec.http.cors |
This package contains Cross Origin Resource Sharing (CORS) related classes.
|
io.netty.handler.codec.http.multipart |
HTTP multipart support.
|
io.netty.handler.codec.http.websocketx |
Encoder, decoder, handshakers and their related message types for
Web Socket data frames.
|
io.netty.handler.codec.marshalling |
Decoder and Encoder which uses JBoss Marshalling.
|
io.netty.handler.codec.protobuf |
Encoder and decoder which transform a
Google Protocol Buffers
Message into a ByteBuf
and vice versa. |
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.socks |
Encoder, decoder and their related message types for Socks.
|
io.netty.handler.codec.spdy |
Encoder, decoder, session handler and their related message types for the SPDY protocol.
|
io.netty.handler.codec.string |
Encoder and decoder which transform a
String into a
ByteBuf and vice versa. |
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 a
io.netty.channel.ChannelEvent for debugging purpose. |
io.netty.handler.ssl |
SSL ·
TLS implementation based on
SSLEngine |
io.netty.handler.ssl.ocsp |
OCSP stapling,
formally known as the TLS Certificate Status Request extension, is an
alternative approach to the Online Certificate Status Protocol (OCSP)
for checking the revocation status of X.509 digital certificates.
|
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.
|
Modifier and Type | Method and Description |
---|---|
ChannelHandlerContext |
DefaultChannelPipeline.context(ChannelHandler handler) |
ChannelHandlerContext |
ChannelPipeline.context(ChannelHandler handler)
Returns the context object of the specified
ChannelHandler in
this pipeline. |
ChannelHandlerContext |
DefaultChannelPipeline.context(java.lang.Class<? extends ChannelHandler> handlerType) |
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.String name) |
ChannelHandlerContext |
ChannelPipeline.context(java.lang.String name)
Returns the context object of the
ChannelHandler with the
specified name in this pipeline. |
ChannelHandlerContext |
ChannelHandlerContext.fireChannelActive()
A
Channel is active now, which means it is connected. |
ChannelHandlerContext |
ChannelHandlerContext.fireChannelInactive()
A
Channel is inactive now, which means it is closed. |
ChannelHandlerContext |
ChannelHandlerContext.fireChannelRead(java.lang.Object msg)
A
Channel received a message. |
ChannelHandlerContext |
ChannelHandlerContext.fireChannelReadComplete()
Triggers an
ChannelInboundHandler.channelReadComplete(ChannelHandlerContext)
event to the next ChannelInboundHandler in the ChannelPipeline . |
ChannelHandlerContext |
ChannelHandlerContext.fireChannelRegistered()
|
ChannelHandlerContext |
ChannelHandlerContext.fireChannelUnregistered()
|
ChannelHandlerContext |
ChannelHandlerContext.fireChannelWritabilityChanged()
Triggers an
ChannelInboundHandler.channelWritabilityChanged(ChannelHandlerContext)
event to the next ChannelInboundHandler in the ChannelPipeline . |
ChannelHandlerContext |
ChannelHandlerContext.fireExceptionCaught(java.lang.Throwable cause)
A
Channel received an Throwable in one of its inbound operations. |
ChannelHandlerContext |
ChannelHandlerContext.fireUserEventTriggered(java.lang.Object evt)
A
Channel received an user defined event. |
ChannelHandlerContext |
DefaultChannelPipeline.firstContext() |
ChannelHandlerContext |
ChannelPipeline.firstContext()
Returns the context of the first
ChannelHandler in this pipeline. |
ChannelHandlerContext |
ChannelHandlerContext.flush()
Request to flush all pending messages via this ChannelOutboundInvoker.
|
ChannelHandlerContext |
DefaultChannelPipeline.lastContext() |
ChannelHandlerContext |
ChannelPipeline.lastContext()
Returns the context of the last
ChannelHandler in this pipeline. |
ChannelHandlerContext |
ChannelHandlerContext.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 |
---|---|
void |
CombinedChannelDuplexHandler.bind(ChannelHandlerContext ctx,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
void |
ChannelOutboundHandlerAdapter.bind(ChannelHandlerContext ctx,
java.net.SocketAddress localAddress,
ChannelPromise promise)
Calls
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 |
ChannelDuplexHandler.bind(ChannelHandlerContext ctx,
java.net.SocketAddress localAddress,
ChannelPromise promise)
Calls
bind(SocketAddress, ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
CombinedChannelDuplexHandler.channelActive(ChannelHandlerContext ctx) |
void |
ChannelInboundHandlerAdapter.channelActive(ChannelHandlerContext ctx)
|
void |
ChannelInboundHandler.channelActive(ChannelHandlerContext ctx)
The
Channel of the ChannelHandlerContext is now active |
void |
CombinedChannelDuplexHandler.channelInactive(ChannelHandlerContext ctx) |
void |
ChannelInboundHandlerAdapter.channelInactive(ChannelHandlerContext ctx)
|
void |
ChannelInboundHandler.channelInactive(ChannelHandlerContext ctx)
The
Channel of the ChannelHandlerContext was registered is now inactive and reached its
end of lifetime. |
void |
SimpleChannelInboundHandler.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
CombinedChannelDuplexHandler.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
ChannelInboundHandlerAdapter.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg)
|
void |
ChannelInboundHandler.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg)
Invoked when the current
Channel has read a message from the peer. |
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. |
void |
CombinedChannelDuplexHandler.channelReadComplete(ChannelHandlerContext ctx) |
void |
ChannelInboundHandlerAdapter.channelReadComplete(ChannelHandlerContext ctx)
Calls
fireChannelReadComplete() to forward
to the next ChannelInboundHandler in the ChannelPipeline . |
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 |
CombinedChannelDuplexHandler.channelRegistered(ChannelHandlerContext ctx) |
void |
ChannelInitializer.channelRegistered(ChannelHandlerContext ctx) |
void |
ChannelInboundHandlerAdapter.channelRegistered(ChannelHandlerContext ctx)
|
void |
ChannelInboundHandler.channelRegistered(ChannelHandlerContext ctx)
|
void |
CombinedChannelDuplexHandler.channelUnregistered(ChannelHandlerContext ctx) |
void |
ChannelInboundHandlerAdapter.channelUnregistered(ChannelHandlerContext ctx)
Calls
fireChannelUnregistered() to forward
to the next ChannelInboundHandler in the ChannelPipeline . |
void |
ChannelInboundHandler.channelUnregistered(ChannelHandlerContext ctx)
|
void |
CombinedChannelDuplexHandler.channelWritabilityChanged(ChannelHandlerContext ctx) |
void |
ChannelInboundHandlerAdapter.channelWritabilityChanged(ChannelHandlerContext ctx)
Calls
fireChannelWritabilityChanged() to forward
to the next ChannelInboundHandler in the ChannelPipeline . |
void |
ChannelInboundHandler.channelWritabilityChanged(ChannelHandlerContext ctx)
Gets called once the writable state of a
Channel changed. |
void |
CombinedChannelDuplexHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
ChannelOutboundHandlerAdapter.close(ChannelHandlerContext ctx,
ChannelPromise promise)
|
void |
ChannelOutboundHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise)
Called once a close operation is made.
|
void |
ChannelDuplexHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise)
|
void |
CombinedChannelDuplexHandler.connect(ChannelHandlerContext ctx,
java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
void |
ChannelOutboundHandlerAdapter.connect(ChannelHandlerContext ctx,
java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise)
Calls
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 |
ChannelDuplexHandler.connect(ChannelHandlerContext ctx,
java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise)
Calls
connect(SocketAddress, SocketAddress, ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
CombinedChannelDuplexHandler.deregister(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
ChannelOutboundHandlerAdapter.deregister(ChannelHandlerContext ctx,
ChannelPromise promise)
Calls
deregister(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 |
ChannelDuplexHandler.deregister(ChannelHandlerContext ctx,
ChannelPromise promise)
|
void |
CombinedChannelDuplexHandler.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
ChannelOutboundHandlerAdapter.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise)
Calls
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 |
ChannelDuplexHandler.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise)
Calls
disconnect(ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
CombinedChannelDuplexHandler.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 |
ChannelInboundHandlerAdapter.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause)
|
void |
ChannelInboundHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause)
Gets called if a
Throwable was thrown. |
void |
ChannelHandlerAdapter.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause)
|
void |
ChannelHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause)
Deprecated.
is part of
ChannelInboundHandler |
void |
CombinedChannelDuplexHandler.flush(ChannelHandlerContext ctx) |
void |
ChannelOutboundHandlerAdapter.flush(ChannelHandlerContext ctx)
|
void |
ChannelOutboundHandler.flush(ChannelHandlerContext ctx)
Called once a flush operation is made.
|
void |
ChannelDuplexHandler.flush(ChannelHandlerContext ctx)
|
void |
CombinedChannelDuplexHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
ChannelInitializer.handlerAdded(ChannelHandlerContext ctx)
Do nothing by default, sub-classes may override this method.
|
void |
ChannelHandlerAdapter.handlerAdded(ChannelHandlerContext ctx)
Do nothing by default, sub-classes may override this method.
|
void |
ChannelHandler.handlerAdded(ChannelHandlerContext ctx)
Gets called after the
ChannelHandler was added to the actual context and it's ready to handle events. |
void |
CombinedChannelDuplexHandler.handlerRemoved(ChannelHandlerContext ctx) |
void |
ChannelHandlerAdapter.handlerRemoved(ChannelHandlerContext ctx)
Do nothing by default, sub-classes may override this method.
|
void |
ChannelHandler.handlerRemoved(ChannelHandlerContext ctx)
Gets called after the
ChannelHandler was removed from the actual context and it doesn't handle events
anymore. |
void |
CombinedChannelDuplexHandler.read(ChannelHandlerContext ctx) |
void |
ChannelOutboundHandlerAdapter.read(ChannelHandlerContext ctx)
|
void |
ChannelOutboundHandler.read(ChannelHandlerContext ctx)
Intercepts
read() . |
void |
ChannelDuplexHandler.read(ChannelHandlerContext ctx)
|
void |
CombinedChannelDuplexHandler.userEventTriggered(ChannelHandlerContext ctx,
java.lang.Object evt) |
void |
ChannelInboundHandlerAdapter.userEventTriggered(ChannelHandlerContext ctx,
java.lang.Object evt)
Calls
fireUserEventTriggered(Object) to forward
to the next ChannelInboundHandler in the ChannelPipeline . |
void |
ChannelInboundHandler.userEventTriggered(ChannelHandlerContext ctx,
java.lang.Object evt)
Gets called if an user event was triggered.
|
void |
CombinedChannelDuplexHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
void |
ChannelOutboundHandlerAdapter.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise)
Calls
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 |
ChannelDuplexHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise)
Calls
write(Object, ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
Constructor and Description |
---|
PendingWriteQueue(ChannelHandlerContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected ByteBuf |
LengthFieldPrepender.allocateBuffer(ChannelHandlerContext ctx,
ByteBuf msg,
boolean preferDirect) |
protected ByteBuf |
MessageToByteEncoder.allocateBuffer(ChannelHandlerContext ctx,
I msg,
boolean preferDirect)
Allocate a
ByteBuf which will be used as argument of #encode(ChannelHandlerContext, I, ByteBuf) . |
protected void |
ReplayingDecoder.callDecode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
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 . |
void |
ByteToMessageDecoder.channelInactive(ChannelHandlerContext ctx) |
void |
ByteToMessageCodec.channelInactive(ChannelHandlerContext ctx) |
void |
MessageToMessageDecoder.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
MessageToMessageCodec.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
ByteToMessageDecoder.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
ByteToMessageCodec.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
ByteToMessageDecoder.channelReadComplete(ChannelHandlerContext ctx) |
void |
ByteToMessageCodec.channelReadComplete(ChannelHandlerContext ctx) |
protected java.lang.Object |
LineBasedFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf buffer)
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 |
FixedLengthFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in)
Create a frame out of the
ByteBuf and return it. |
protected java.lang.Object |
DelimiterBasedFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf buffer)
Create a frame out of the
ByteBuf and return it. |
protected void |
LineBasedFrameDecoder.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 |
FixedLengthFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
DelimiterBasedFrameDecoder.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 abstract void |
ByteToMessageCodec.decode(ChannelHandlerContext ctx,
ByteBuf in,
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 |
ByteToMessageDecoder.decodeLast(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out)
Is called one last time when the
ChannelHandlerContext goes in-active. |
protected void |
ByteToMessageCodec.decodeLast(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
LengthFieldPrepender.encode(ChannelHandlerContext ctx,
ByteBuf msg,
ByteBuf out) |
protected abstract void |
MessageToByteEncoder.encode(ChannelHandlerContext ctx,
I msg,
ByteBuf out)
Encode a message into a
ByteBuf . |
protected abstract void |
ByteToMessageCodec.encode(ChannelHandlerContext ctx,
I msg,
ByteBuf out) |
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) |
protected ByteBuf |
LengthFieldBasedFrameDecoder.extractFrame(ChannelHandlerContext ctx,
ByteBuf buffer,
int index,
int length)
Extract the sub-region of the specified buffer.
|
void |
ByteToMessageCodec.handlerAdded(ChannelHandlerContext ctx) |
void |
ByteToMessageDecoder.handlerRemoved(ChannelHandlerContext ctx) |
void |
ByteToMessageCodec.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. |
void |
ByteToMessageDecoder.userEventTriggered(ChannelHandlerContext ctx,
java.lang.Object evt) |
void |
MessageToMessageEncoder.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
void |
MessageToMessageCodec.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
void |
MessageToByteEncoder.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
void |
ByteToMessageCodec.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 | Method and Description |
---|---|
protected ByteBuf |
JdkZlibEncoder.allocateBuffer(ChannelHandlerContext ctx,
ByteBuf msg,
boolean preferDirect) |
void |
JdkZlibEncoder.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
JZlibEncoder.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
protected void |
SnappyFramedDecoder.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 |
JZlibDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
SnappyFramedEncoder.encode(ChannelHandlerContext ctx,
ByteBuf in,
ByteBuf out) |
protected void |
JdkZlibEncoder.encode(ChannelHandlerContext ctx,
ByteBuf uncompressed,
ByteBuf out) |
protected void |
JZlibEncoder.encode(ChannelHandlerContext ctx,
ByteBuf in,
ByteBuf out) |
void |
JdkZlibEncoder.handlerAdded(ChannelHandlerContext ctx) |
void |
JZlibEncoder.handlerAdded(ChannelHandlerContext ctx) |
protected void |
JdkZlibDecoder.handlerRemoved0(ChannelHandlerContext ctx) |
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) |
Modifier and Type | Field and Description |
---|---|
protected ChannelHandlerContext |
HttpContentDecoder.ctx |
Modifier and Type | Method and Description |
---|---|
void |
HttpObjectAggregator.channelInactive(ChannelHandlerContext ctx) |
void |
HttpContentEncoder.channelInactive(ChannelHandlerContext ctx) |
void |
HttpContentDecoder.channelInactive(ChannelHandlerContext ctx) |
void |
HttpServerKeepAliveHandler.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
protected void |
HttpObjectDecoder.decode(ChannelHandlerContext ctx,
ByteBuf buffer,
java.util.List<java.lang.Object> out) |
protected void |
HttpObjectAggregator.decode(ChannelHandlerContext ctx,
HttpObject msg,
java.util.List<java.lang.Object> out) |
protected void |
HttpContentDecoder.decode(ChannelHandlerContext ctx,
HttpObject msg,
java.util.List<java.lang.Object> out) |
protected void |
HttpContentEncoder.decode(ChannelHandlerContext ctx,
HttpRequest msg,
java.util.List<java.lang.Object> out) |
protected void |
HttpObjectDecoder.decodeLast(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
HttpContentEncoder.encode(ChannelHandlerContext ctx,
HttpObject msg,
java.util.List<java.lang.Object> out) |
protected void |
HttpObjectEncoder.encode(ChannelHandlerContext ctx,
java.lang.Object msg,
java.util.List<java.lang.Object> out) |
void |
HttpObjectAggregator.handlerAdded(ChannelHandlerContext ctx) |
void |
HttpContentDecoder.handlerAdded(ChannelHandlerContext ctx) |
void |
HttpContentCompressor.handlerAdded(ChannelHandlerContext ctx) |
void |
HttpObjectAggregator.handlerRemoved(ChannelHandlerContext ctx) |
void |
HttpContentEncoder.handlerRemoved(ChannelHandlerContext ctx) |
void |
HttpContentDecoder.handlerRemoved(ChannelHandlerContext ctx) |
HttpContent |
HttpChunkedInput.readChunk(ChannelHandlerContext ctx) |
void |
HttpObjectDecoder.userEventTriggered(ChannelHandlerContext ctx,
java.lang.Object evt) |
void |
HttpServerKeepAliveHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
void |
CorsHandler.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
CorsHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
void |
CorsHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
HttpContent |
HttpPostRequestEncoder.readChunk(ChannelHandlerContext ctx)
Returns the next available HttpChunk.
|
Modifier and Type | Method and Description |
---|---|
void |
WebSocketFrameAggregator.channelInactive(ChannelHandlerContext ctx) |
void |
WebSocket08FrameDecoder.channelInactive(ChannelHandlerContext ctx) |
protected void |
WebSocket08FrameDecoder.checkCloseFrameBody(ChannelHandlerContext ctx,
ByteBuf buffer) |
protected void |
WebSocket08FrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
WebSocket00FrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
WebSocketServerProtocolHandler.decode(ChannelHandlerContext ctx,
WebSocketFrame frame,
java.util.List<java.lang.Object> out) |
protected void |
WebSocketFrameAggregator.decode(ChannelHandlerContext ctx,
WebSocketFrame msg,
java.util.List<java.lang.Object> out) |
protected void |
WebSocketClientProtocolHandler.decode(ChannelHandlerContext ctx,
WebSocketFrame frame,
java.util.List<java.lang.Object> out) |
protected void |
WebSocket08FrameEncoder.encode(ChannelHandlerContext ctx,
WebSocketFrame msg,
java.util.List<java.lang.Object> out) |
protected void |
WebSocket00FrameEncoder.encode(ChannelHandlerContext ctx,
WebSocketFrame msg,
java.util.List<java.lang.Object> out) |
void |
WebSocketServerProtocolHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
void |
WebSocketServerProtocolHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
WebSocketClientProtocolHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
WebSocketFrameAggregator.handlerRemoved(ChannelHandlerContext ctx) |
WebSocketFrame |
WebSocketChunkedInput.readChunk(ChannelHandlerContext ctx)
Fetches a chunked data from the stream.
|
Modifier and Type | Method and Description |
---|---|
protected java.lang.Object |
MarshallingDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in) |
protected void |
CompatibleMarshallingDecoder.decode(ChannelHandlerContext ctx,
ByteBuf buffer,
java.util.List<java.lang.Object> out) |
protected void |
CompatibleMarshallingDecoder.decodeLast(ChannelHandlerContext ctx,
ByteBuf buffer,
java.util.List<java.lang.Object> out) |
protected void |
MarshallingEncoder.encode(ChannelHandlerContext ctx,
java.lang.Object msg,
ByteBuf out) |
protected void |
CompatibleMarshallingEncoder.encode(ChannelHandlerContext ctx,
java.lang.Object msg,
ByteBuf out) |
void |
CompatibleMarshallingDecoder.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
protected ByteBuf |
MarshallingDecoder.extractFrame(ChannelHandlerContext ctx,
ByteBuf buffer,
int index,
int length) |
org.jboss.marshalling.Marshaller |
ThreadLocalMarshallerProvider.getMarshaller(ChannelHandlerContext ctx) |
org.jboss.marshalling.Marshaller |
MarshallerProvider.getMarshaller(ChannelHandlerContext ctx)
Get a
Marshaller for the given ChannelHandlerContext |
org.jboss.marshalling.Marshaller |
DefaultMarshallerProvider.getMarshaller(ChannelHandlerContext ctx) |
org.jboss.marshalling.Unmarshaller |
UnmarshallerProvider.getUnmarshaller(ChannelHandlerContext ctx)
Get the
Unmarshaller for the given ChannelHandlerContext |
org.jboss.marshalling.Unmarshaller |
ThreadLocalUnmarshallerProvider.getUnmarshaller(ChannelHandlerContext ctx) |
org.jboss.marshalling.Unmarshaller |
DefaultUnmarshallerProvider.getUnmarshaller(ChannelHandlerContext ctx) |
org.jboss.marshalling.Unmarshaller |
ContextBoundUnmarshallerProvider.getUnmarshaller(ChannelHandlerContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected void |
ProtobufVarint32FrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
ProtobufDecoder.decode(ChannelHandlerContext ctx,
ByteBuf msg,
java.util.List<java.lang.Object> out) |
protected void |
ProtobufVarint32LengthFieldPrepender.encode(ChannelHandlerContext ctx,
ByteBuf msg,
ByteBuf out) |
protected void |
ProtobufEncoder.encode(ChannelHandlerContext ctx,
MessageLiteOrBuilder msg,
java.util.List<java.lang.Object> out) |
Modifier and Type | Method and Description |
---|---|
protected void |
SctpMessageCompletionHandler.decode(ChannelHandlerContext ctx,
SctpMessage msg,
java.util.List<java.lang.Object> out) |
protected void |
SctpInboundByteStreamHandler.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 |
ObjectEncoder.encode(ChannelHandlerContext ctx,
java.io.Serializable msg,
ByteBuf out) |
protected void |
CompatibleObjectEncoder.encode(ChannelHandlerContext ctx,
java.io.Serializable msg,
ByteBuf out) |
Modifier and Type | Method and Description |
---|---|
protected void |
SocksInitResponseDecoder.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 |
SocksCmdResponseDecoder.decode(ChannelHandlerContext ctx,
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 |
SocksAuthResponseDecoder.decode(ChannelHandlerContext channelHandlerContext,
ByteBuf byteBuf,
java.util.List<java.lang.Object> out) |
protected void |
SocksAuthRequestDecoder.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 |
---|---|
void |
SpdyFrameCodec.bind(ChannelHandlerContext ctx,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
void |
SpdySessionHandler.channelInactive(ChannelHandlerContext ctx) |
void |
SpdySessionHandler.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
SpdyFrameCodec.channelReadComplete(ChannelHandlerContext ctx) |
void |
SpdySessionHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
SpdyFrameCodec.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
protected abstract void |
SpdyOrHttpChooser.configureHttp1(ChannelHandlerContext ctx)
Deprecated.
Configures the
Channel of the specified ctx for HTTP/1. |
protected abstract void |
SpdyOrHttpChooser.configureSpdy(ChannelHandlerContext ctx,
SpdyVersion version)
Deprecated.
Configures the
Channel of the specified ctx for HTTP/2. |
void |
SpdyFrameCodec.connect(ChannelHandlerContext ctx,
java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
protected void |
SpdyOrHttpChooser.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out)
Deprecated.
|
protected void |
SpdyFrameCodec.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
SpdyHttpResponseStreamIdHandler.decode(ChannelHandlerContext ctx,
java.lang.Object msg,
java.util.List<java.lang.Object> out) |
protected void |
SpdyHttpDecoder.decode(ChannelHandlerContext ctx,
SpdyFrame msg,
java.util.List<java.lang.Object> out) |
void |
SpdyFrameCodec.deregister(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
SpdyFrameCodec.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise) |
protected void |
SpdyHttpResponseStreamIdHandler.encode(ChannelHandlerContext ctx,
HttpMessage msg,
java.util.List<java.lang.Object> out) |
protected void |
SpdyHttpEncoder.encode(ChannelHandlerContext ctx,
HttpObject msg,
java.util.List<java.lang.Object> out) |
void |
SpdySessionHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
void |
SpdyOrHttpChooser.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause)
Deprecated.
|
void |
SpdyFrameCodec.flush(ChannelHandlerContext ctx) |
void |
SpdyFrameCodec.handlerAdded(ChannelHandlerContext ctx) |
void |
SpdyFrameCodec.read(ChannelHandlerContext ctx) |
void |
SpdySessionHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
void |
SpdyFrameCodec.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
protected void |
StringDecoder.decode(ChannelHandlerContext ctx,
ByteBuf 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 |
---|---|
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) |
void |
FlushConsolidationHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
FlushConsolidationHandler.handlerRemoved(ChannelHandlerContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
UniqueIpFilter.accept(ChannelHandlerContext ctx,
java.net.InetSocketAddress remoteAddress) |
protected boolean |
RuleBasedIpFilter.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) . |
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 message) |
void |
LoggingHandler.userEventTriggered(ChannelHandlerContext ctx,
java.lang.Object evt) |
void |
LoggingHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
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 |
SslHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
protected abstract void |
ApplicationProtocolNegotiationHandler.configurePipeline(ChannelHandlerContext ctx,
java.lang.String protocol)
Invoked on successful initial SSL/TLS handshake.
|
void |
SslHandler.connect(ChannelHandlerContext ctx,
java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
protected void |
SslHandler.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
SniHandler.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) |
void |
SslHandler.deregister(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
SslHandler.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
SslHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
void |
ApplicationProtocolNegotiationHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
void |
SslHandler.flush(ChannelHandlerContext ctx) |
void |
SslHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
SslHandler.handlerRemoved0(ChannelHandlerContext ctx) |
protected void |
ApplicationProtocolNegotiationHandler.handshakeFailure(ChannelHandlerContext ctx,
java.lang.Throwable cause)
Invoked on failed initial SSL/TLS handshake.
|
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.
|
void |
SslHandler.read(ChannelHandlerContext ctx) |
void |
ApplicationProtocolNegotiationHandler.userEventTriggered(ChannelHandlerContext ctx,
java.lang.Object evt) |
void |
SslHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
void |
OcspClientHandler.userEventTriggered(ChannelHandlerContext ctx,
java.lang.Object evt) |
protected abstract boolean |
OcspClientHandler.verify(ChannelHandlerContext ctx,
ReferenceCountedOpenSslEngine engine) |
Modifier and Type | Method and Description |
---|---|
void |
ChunkedWriteHandler.channelInactive(ChannelHandlerContext ctx) |
void |
ChunkedWriteHandler.channelWritabilityChanged(ChannelHandlerContext ctx) |
void |
ChunkedWriteHandler.flush(ChannelHandlerContext ctx) |
void |
ChunkedWriteHandler.handlerAdded(ChannelHandlerContext ctx) |
ByteBuf |
ChunkedStream.readChunk(ChannelHandlerContext ctx) |
ByteBuf |
ChunkedNioStream.readChunk(ChannelHandlerContext ctx) |
ByteBuf |
ChunkedNioFile.readChunk(ChannelHandlerContext ctx) |
B |
ChunkedInput.readChunk(ChannelHandlerContext ctx)
Fetches a chunked data from the stream.
|
ByteBuf |
ChunkedFile.readChunk(ChannelHandlerContext ctx) |
void |
ChunkedWriteHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
void |
IdleStateHandler.channelActive(ChannelHandlerContext ctx) |
protected void |
ReadTimeoutHandler.channelIdle(ChannelHandlerContext ctx,
IdleStateEvent evt) |
protected void |
IdleStateHandler.channelIdle(ChannelHandlerContext ctx,
IdleStateEvent evt)
Is called when an
IdleStateEvent should be fired. |
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 |
WriteTimeoutHandler.handlerRemoved(ChannelHandlerContext ctx) |
void |
IdleStateHandler.handlerRemoved(ChannelHandlerContext ctx) |
protected void |
ReadTimeoutHandler.readTimedOut(ChannelHandlerContext ctx)
Is called when a read timeout was detected.
|
void |
WriteTimeoutHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
void |
IdleStateHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
protected void |
WriteTimeoutHandler.writeTimedOut(ChannelHandlerContext ctx)
Is called when a write timeout was detected
|
Modifier and Type | Method and Description |
---|---|
void |
GlobalChannelTrafficShapingHandler.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
AbstractTrafficShapingHandler.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
AbstractTrafficShapingHandler.channelRegistered(ChannelHandlerContext ctx) |
protected long |
GlobalChannelTrafficShapingHandler.checkWaitReadTime(ChannelHandlerContext ctx,
long wait,
long now) |
void |
GlobalTrafficShapingHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
GlobalChannelTrafficShapingHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
ChannelTrafficShapingHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
GlobalTrafficShapingHandler.handlerRemoved(ChannelHandlerContext ctx) |
void |
GlobalChannelTrafficShapingHandler.handlerRemoved(ChannelHandlerContext ctx) |
void |
ChannelTrafficShapingHandler.handlerRemoved(ChannelHandlerContext ctx) |
protected void |
GlobalChannelTrafficShapingHandler.informReadOperation(ChannelHandlerContext ctx,
long now) |
protected static boolean |
AbstractTrafficShapingHandler.isHandlerActive(ChannelHandlerContext ctx) |
void |
AbstractTrafficShapingHandler.read(ChannelHandlerContext ctx) |
protected void |
AbstractTrafficShapingHandler.submitWrite(ChannelHandlerContext ctx,
java.lang.Object msg,
long delay,
ChannelPromise promise)
Deprecated.
|
protected void |
GlobalChannelTrafficShapingHandler.submitWrite(ChannelHandlerContext ctx,
java.lang.Object msg,
long size,
long writedelay,
long now,
ChannelPromise promise) |
void |
GlobalChannelTrafficShapingHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
void |
AbstractTrafficShapingHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
Copyright © 2008–2018 The Netty Project. All rights reserved.