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.dns |
DNS codec.
|
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.http.websocketx.extensions |
Encoder, decoder, handshakers to handle
WebSocket Extensions.
|
io.netty.handler.codec.http2 |
Handlers for sending and receiving HTTP/2 frames.
|
io.netty.handler.codec.json |
JSON specific codecs.
|
io.netty.handler.codec.marshalling |
Decoder and Encoder which uses JBoss Marshalling.
|
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.protobuf |
Encoder and decoder which transform a
Google Protocol Buffers
Message and com.google.protobuf.nano.MessageNano into a
ByteBuf and vice versa. |
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.spdy |
Encoder, decoder, session handler and their related message types for the SPDY protocol.
|
io.netty.handler.codec.stomp |
STOMP codec
|
io.netty.handler.codec.string | |
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.proxy |
Adds support for client connections via proxy protocols such as
SOCKS and
HTTP CONNECT tunneling
|
io.netty.handler.ssl | |
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(Class<? extends ChannelHandler> handlerType) |
ChannelHandlerContext |
ChannelPipeline.context(Class<? extends ChannelHandler> handlerType)
Returns the context object of the
ChannelHandler of the
specified type in this pipeline. |
ChannelHandlerContext |
DefaultChannelPipeline.context(String name) |
ChannelHandlerContext |
ChannelPipeline.context(String name)
Returns the context object of the
ChannelHandler with the
specified name in this pipeline. |
ChannelHandlerContext |
ChannelHandlerContext.fireChannelActive() |
ChannelHandlerContext |
ChannelHandlerContext.fireChannelInactive() |
ChannelHandlerContext |
ChannelHandlerContext.fireChannelRead(Object msg) |
ChannelHandlerContext |
ChannelHandlerContext.fireChannelReadComplete() |
ChannelHandlerContext |
ChannelHandlerContext.fireChannelRegistered() |
ChannelHandlerContext |
ChannelHandlerContext.fireChannelUnregistered() |
ChannelHandlerContext |
ChannelHandlerContext.fireChannelWritabilityChanged() |
ChannelHandlerContext |
ChannelHandlerContext.fireExceptionCaught(Throwable cause) |
ChannelHandlerContext |
ChannelHandlerContext.fireUserEventTriggered(Object evt) |
ChannelHandlerContext |
DefaultChannelPipeline.firstContext() |
ChannelHandlerContext |
ChannelPipeline.firstContext()
Returns the context of the first
ChannelHandler in this pipeline. |
ChannelHandlerContext |
ChannelHandlerContext.flush() |
ChannelHandlerContext |
DefaultChannelPipeline.lastContext() |
ChannelHandlerContext |
ChannelPipeline.lastContext()
Returns the context of the last
ChannelHandler in this pipeline. |
ChannelHandlerContext |
ChannelHandlerContext.read() |
Modifier and Type | Method and Description |
---|---|
void |
CombinedChannelDuplexHandler.bind(ChannelHandlerContext ctx,
SocketAddress localAddress,
ChannelPromise promise) |
void |
ChannelOutboundHandlerAdapter.bind(ChannelHandlerContext ctx,
SocketAddress localAddress,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.bind(SocketAddress, ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
ChannelOutboundHandler.bind(ChannelHandlerContext ctx,
SocketAddress localAddress,
ChannelPromise promise)
Called once a bind operation is made.
|
void |
ChannelDuplexHandler.bind(ChannelHandlerContext ctx,
SocketAddress localAddress,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.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,
Object msg) |
void |
CombinedChannelDuplexHandler.channelRead(ChannelHandlerContext ctx,
Object msg) |
void |
ChannelInboundHandlerAdapter.channelRead(ChannelHandlerContext ctx,
Object msg)
|
void |
ChannelInboundHandler.channelRead(ChannelHandlerContext ctx,
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)
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 |
ChannelDuplexHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.close(ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
CombinedChannelDuplexHandler.connect(ChannelHandlerContext ctx,
SocketAddress remoteAddress,
SocketAddress localAddress,
ChannelPromise promise) |
void |
ChannelOutboundHandlerAdapter.connect(ChannelHandlerContext ctx,
SocketAddress remoteAddress,
SocketAddress localAddress,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.connect(SocketAddress, SocketAddress, ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
ChannelOutboundHandler.connect(ChannelHandlerContext ctx,
SocketAddress remoteAddress,
SocketAddress localAddress,
ChannelPromise promise)
Called once a connect operation is made.
|
void |
ChannelDuplexHandler.connect(ChannelHandlerContext ctx,
SocketAddress remoteAddress,
SocketAddress localAddress,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.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
ChannelOutboundInvoker.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)
Calls
ChannelOutboundInvoker.close(ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
CombinedChannelDuplexHandler.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
ChannelOutboundHandlerAdapter.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 |
ChannelDuplexHandler.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.disconnect(ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
CombinedChannelDuplexHandler.exceptionCaught(ChannelHandlerContext ctx,
Throwable cause) |
void |
ChannelInitializer.exceptionCaught(ChannelHandlerContext ctx,
Throwable cause)
|
void |
ChannelInboundHandlerAdapter.exceptionCaught(ChannelHandlerContext ctx,
Throwable cause)
|
void |
ChannelInboundHandler.exceptionCaught(ChannelHandlerContext ctx,
Throwable cause)
Gets called if a
Throwable was thrown. |
void |
ChannelHandlerAdapter.exceptionCaught(ChannelHandlerContext ctx,
Throwable cause)
|
void |
ChannelHandler.exceptionCaught(ChannelHandlerContext ctx,
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,
Object evt) |
void |
ChannelInboundHandlerAdapter.userEventTriggered(ChannelHandlerContext ctx,
Object evt)
Calls
fireUserEventTriggered(Object) to forward
to the next ChannelInboundHandler in the ChannelPipeline . |
void |
ChannelInboundHandler.userEventTriggered(ChannelHandlerContext ctx,
Object evt)
Gets called if an user event was triggered.
|
void |
CombinedChannelDuplexHandler.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise) |
void |
ChannelOutboundHandlerAdapter.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.write(Object, ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
ChannelOutboundHandler.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise)
Called once a write operation is made.
|
void |
ChannelDuplexHandler.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.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 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,
SocketAddress localAddress,
ChannelPromise promise) |
protected void |
ReplayingDecoder.callDecode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
ByteToMessageDecoder.callDecode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out)
Called once data should be decoded from the given
ByteBuf . |
void |
DatagramPacketDecoder.channelActive(ChannelHandlerContext ctx) |
void |
MessageAggregator.channelInactive(ChannelHandlerContext ctx) |
void |
DatagramPacketDecoder.channelInactive(ChannelHandlerContext ctx) |
void |
ByteToMessageDecoder.channelInactive(ChannelHandlerContext ctx) |
void |
ByteToMessageCodec.channelInactive(ChannelHandlerContext ctx) |
void |
MessageToMessageDecoder.channelRead(ChannelHandlerContext ctx,
Object msg) |
void |
MessageToMessageCodec.channelRead(ChannelHandlerContext ctx,
Object msg) |
void |
ByteToMessageDecoder.channelRead(ChannelHandlerContext ctx,
Object msg) |
void |
ByteToMessageCodec.channelRead(ChannelHandlerContext ctx,
Object msg) |
void |
MessageAggregator.channelReadComplete(ChannelHandlerContext ctx) |
void |
DatagramPacketDecoder.channelReadComplete(ChannelHandlerContext ctx) |
void |
ByteToMessageDecoder.channelReadComplete(ChannelHandlerContext ctx) |
void |
ByteToMessageCodec.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,
SocketAddress remoteAddress,
SocketAddress localAddress,
ChannelPromise promise) |
protected Object |
LineBasedFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf buffer)
Create a frame out of the
ByteBuf and return it. |
protected Object |
LengthFieldBasedFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in)
Create a frame out of the
ByteBuf and return it. |
protected Object |
FixedLengthFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in)
Create a frame out of the
ByteBuf and return it. |
protected 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,
List<Object> out) |
protected void |
LengthFieldBasedFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
FixedLengthFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
DelimiterBasedFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected abstract void |
ByteToMessageDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out)
Decode the from one
ByteBuf to an other. |
protected abstract void |
ByteToMessageCodec.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
DatagramPacketDecoder.decode(ChannelHandlerContext ctx,
DatagramPacket msg,
List<Object> out) |
protected abstract void |
MessageToMessageDecoder.decode(ChannelHandlerContext ctx,
I msg,
List<Object> out)
Decode from one message to an other.
|
protected void |
MessageAggregator.decode(ChannelHandlerContext ctx,
I msg,
List<Object> out) |
protected abstract void |
MessageToMessageCodec.decode(ChannelHandlerContext ctx,
INBOUND_IN msg,
List<Object> out) |
protected void |
ByteToMessageDecoder.decodeLast(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out)
Is called one last time when the
ChannelHandlerContext goes in-active. |
protected void |
ByteToMessageCodec.decodeLast(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
void |
DatagramPacketEncoder.deregister(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
DatagramPacketEncoder.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise) |
protected void |
DatagramPacketEncoder.encode(ChannelHandlerContext ctx,
AddressedEnvelope<M,InetSocketAddress> msg,
List<Object> out) |
protected void |
LengthFieldPrepender.encode(ChannelHandlerContext ctx,
ByteBuf msg,
List<Object> 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,
List<Object> out)
Encode from one message to an other.
|
protected abstract void |
MessageToMessageCodec.encode(ChannelHandlerContext ctx,
OUTBOUND_IN msg,
List<Object> out) |
void |
DatagramPacketEncoder.exceptionCaught(ChannelHandlerContext ctx,
Throwable cause) |
void |
DatagramPacketDecoder.exceptionCaught(ChannelHandlerContext ctx,
Throwable cause) |
protected ByteBuf |
LengthFieldBasedFrameDecoder.extractFrame(ChannelHandlerContext ctx,
ByteBuf buffer,
int index,
int length)
Extract the sub-region of the specified buffer.
|
void |
DatagramPacketEncoder.flush(ChannelHandlerContext ctx) |
protected void |
MessageAggregator.handleOversizedMessage(ChannelHandlerContext ctx,
S oversized)
Invoked when an incoming request exceeds the maximum content length.
|
void |
MessageAggregator.handlerAdded(ChannelHandlerContext ctx) |
void |
DatagramPacketEncoder.handlerAdded(ChannelHandlerContext ctx) |
void |
DatagramPacketDecoder.handlerAdded(ChannelHandlerContext ctx) |
void |
ByteToMessageCodec.handlerAdded(ChannelHandlerContext ctx) |
void |
MessageAggregator.handlerRemoved(ChannelHandlerContext ctx) |
void |
DatagramPacketEncoder.handlerRemoved(ChannelHandlerContext ctx) |
void |
DatagramPacketDecoder.handlerRemoved(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 |
DatagramPacketEncoder.read(ChannelHandlerContext ctx) |
void |
DatagramPacketDecoder.userEventTriggered(ChannelHandlerContext ctx,
Object evt) |
void |
ByteToMessageDecoder.userEventTriggered(ChannelHandlerContext ctx,
Object evt) |
void |
MessageToMessageEncoder.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise) |
void |
MessageToMessageCodec.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise) |
void |
MessageToByteEncoder.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise) |
void |
ByteToMessageCodec.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
protected void |
Base64Decoder.decode(ChannelHandlerContext ctx,
ByteBuf msg,
List<Object> out) |
protected void |
Base64Encoder.encode(ChannelHandlerContext ctx,
ByteBuf msg,
List<Object> out) |
Modifier and Type | Method and Description |
---|---|
protected void |
ByteArrayDecoder.decode(ChannelHandlerContext ctx,
ByteBuf msg,
List<Object> out) |
protected void |
ByteArrayEncoder.encode(ChannelHandlerContext ctx,
byte[] msg,
List<Object> out) |
Modifier and Type | Method and Description |
---|---|
protected ByteBuf |
LzmaFrameEncoder.allocateBuffer(ChannelHandlerContext ctx,
ByteBuf in,
boolean preferDirect) |
protected ByteBuf |
Lz4FrameEncoder.allocateBuffer(ChannelHandlerContext ctx,
ByteBuf msg,
boolean preferDirect) |
protected ByteBuf |
JdkZlibEncoder.allocateBuffer(ChannelHandlerContext ctx,
ByteBuf msg,
boolean preferDirect) |
void |
Lz4FrameEncoder.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
JdkZlibEncoder.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
JZlibEncoder.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
Bzip2Encoder.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
protected void |
SnappyFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
LzfDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
Lz4FrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
JdkZlibDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
JZlibDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
FastLzFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
Bzip2Decoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
SnappyFrameEncoder.encode(ChannelHandlerContext ctx,
ByteBuf in,
ByteBuf out) |
protected void |
LzmaFrameEncoder.encode(ChannelHandlerContext ctx,
ByteBuf in,
ByteBuf out) |
protected void |
LzfEncoder.encode(ChannelHandlerContext ctx,
ByteBuf in,
ByteBuf out) |
protected void |
Lz4FrameEncoder.encode(ChannelHandlerContext ctx,
ByteBuf in,
ByteBuf out)
Encode a message into a
ByteBuf . |
protected void |
JdkZlibEncoder.encode(ChannelHandlerContext ctx,
ByteBuf uncompressed,
ByteBuf out) |
protected void |
JZlibEncoder.encode(ChannelHandlerContext ctx,
ByteBuf in,
ByteBuf out) |
protected void |
FastLzFrameEncoder.encode(ChannelHandlerContext ctx,
ByteBuf in,
ByteBuf out) |
protected void |
Bzip2Encoder.encode(ChannelHandlerContext ctx,
ByteBuf in,
ByteBuf out) |
void |
Lz4FrameEncoder.flush(ChannelHandlerContext ctx) |
void |
Lz4FrameEncoder.handlerAdded(ChannelHandlerContext ctx) |
void |
JdkZlibEncoder.handlerAdded(ChannelHandlerContext ctx) |
void |
JZlibEncoder.handlerAdded(ChannelHandlerContext ctx) |
void |
Bzip2Encoder.handlerAdded(ChannelHandlerContext ctx) |
void |
Lz4FrameEncoder.handlerRemoved(ChannelHandlerContext ctx) |
protected void |
JdkZlibDecoder.handlerRemoved0(ChannelHandlerContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected ByteBuf |
DatagramDnsQueryEncoder.allocateBuffer(ChannelHandlerContext ctx,
AddressedEnvelope<DnsQuery,InetSocketAddress> msg)
Allocate a
ByteBuf which will be used for constructing a datagram packet. |
protected ByteBuf |
DatagramDnsResponseEncoder.allocateBuffer(ChannelHandlerContext ctx,
AddressedEnvelope<DnsResponse,InetSocketAddress> msg)
Allocate a
ByteBuf which will be used for constructing a datagram packet. |
protected void |
DatagramDnsResponseDecoder.decode(ChannelHandlerContext ctx,
DatagramPacket packet,
List<Object> out) |
protected void |
DatagramDnsQueryDecoder.decode(ChannelHandlerContext ctx,
DatagramPacket packet,
List<Object> out) |
protected void |
DatagramDnsQueryEncoder.encode(ChannelHandlerContext ctx,
AddressedEnvelope<DnsQuery,InetSocketAddress> in,
List<Object> out) |
protected void |
DatagramDnsResponseEncoder.encode(ChannelHandlerContext ctx,
AddressedEnvelope<DnsResponse,InetSocketAddress> in,
List<Object> out) |
Modifier and Type | Method and Description |
---|---|
void |
HAProxyMessageDecoder.channelRead(ChannelHandlerContext ctx,
Object msg) |
protected void |
HAProxyMessageDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
Modifier and Type | Field and Description |
---|---|
protected ChannelHandlerContext |
HttpContentDecoder.ctx |
Modifier and Type | Method and Description |
---|---|
void |
HttpClientUpgradeHandler.bind(ChannelHandlerContext ctx,
SocketAddress localAddress,
ChannelPromise promise) |
void |
HttpContentEncoder.channelInactive(ChannelHandlerContext ctx) |
void |
HttpContentDecoder.channelInactive(ChannelHandlerContext ctx) |
void |
HttpServerKeepAliveHandler.channelRead(ChannelHandlerContext ctx,
Object msg) |
void |
HttpServerExpectContinueHandler.channelRead(ChannelHandlerContext ctx,
Object msg) |
void |
HttpClientUpgradeHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
HttpClientUpgradeHandler.connect(ChannelHandlerContext ctx,
SocketAddress remoteAddress,
SocketAddress localAddress,
ChannelPromise promise) |
protected void |
HttpObjectDecoder.decode(ChannelHandlerContext ctx,
ByteBuf buffer,
List<Object> out) |
protected void |
HttpServerUpgradeHandler.decode(ChannelHandlerContext ctx,
HttpObject msg,
List<Object> out) |
protected void |
HttpContentDecoder.decode(ChannelHandlerContext ctx,
HttpObject msg,
List<Object> out) |
protected void |
HttpClientUpgradeHandler.decode(ChannelHandlerContext ctx,
HttpObject msg,
List<Object> out) |
protected void |
HttpContentEncoder.decode(ChannelHandlerContext ctx,
HttpRequest msg,
List<Object> out) |
protected void |
HttpObjectDecoder.decodeLast(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
void |
HttpClientUpgradeHandler.deregister(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
HttpClientUpgradeHandler.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise) |
protected void |
HttpContentEncoder.encode(ChannelHandlerContext ctx,
HttpObject msg,
List<Object> out) |
protected void |
HttpObjectEncoder.encode(ChannelHandlerContext ctx,
Object msg,
List<Object> out) |
void |
HttpClientUpgradeHandler.flush(ChannelHandlerContext ctx) |
protected void |
HttpObjectAggregator.handleOversizedMessage(ChannelHandlerContext ctx,
HttpMessage oversized) |
void |
HttpContentDecoder.handlerAdded(ChannelHandlerContext ctx) |
void |
HttpContentCompressor.handlerAdded(ChannelHandlerContext ctx) |
void |
HttpContentEncoder.handlerRemoved(ChannelHandlerContext ctx) |
void |
HttpContentDecoder.handlerRemoved(ChannelHandlerContext ctx) |
void |
HttpClientUpgradeHandler.SourceCodec.prepareUpgradeFrom(ChannelHandlerContext ctx)
Removes or disables the encoder of this codec so that the
HttpClientUpgradeHandler.UpgradeCodec can send an initial greeting
(if any). |
void |
HttpClientCodec.prepareUpgradeFrom(ChannelHandlerContext ctx)
Prepares to upgrade to another protocol from HTTP.
|
boolean |
HttpServerUpgradeHandler.UpgradeCodec.prepareUpgradeResponse(ChannelHandlerContext ctx,
FullHttpRequest upgradeRequest,
HttpHeaders upgradeHeaders)
Prepares the
upgradeHeaders for a protocol update based upon the contents of upgradeRequest . |
void |
HttpClientUpgradeHandler.read(ChannelHandlerContext ctx) |
HttpContent |
HttpChunkedInput.readChunk(ChannelHandlerContext ctx)
Deprecated.
|
Collection<CharSequence> |
HttpClientUpgradeHandler.UpgradeCodec.setUpgradeHeaders(ChannelHandlerContext ctx,
HttpRequest upgradeRequest)
Sets any protocol-specific headers required to the upgrade request.
|
void |
HttpServerUpgradeHandler.SourceCodec.upgradeFrom(ChannelHandlerContext ctx)
Removes this codec (i.e. all associated handlers) from the pipeline.
|
void |
HttpServerCodec.upgradeFrom(ChannelHandlerContext ctx)
Upgrades to another protocol from HTTP.
|
void |
HttpClientUpgradeHandler.SourceCodec.upgradeFrom(ChannelHandlerContext ctx)
Removes this codec (i.e. all associated handlers) from the pipeline.
|
void |
HttpClientCodec.upgradeFrom(ChannelHandlerContext ctx)
Upgrades to another protocol from HTTP.
|
void |
HttpServerUpgradeHandler.UpgradeCodec.upgradeTo(ChannelHandlerContext ctx,
FullHttpRequest upgradeRequest)
Performs an HTTP protocol upgrade from the source codec.
|
void |
HttpClientUpgradeHandler.UpgradeCodec.upgradeTo(ChannelHandlerContext ctx,
FullHttpResponse upgradeResponse)
Performs an HTTP protocol upgrade from the source codec.
|
void |
HttpObjectDecoder.userEventTriggered(ChannelHandlerContext ctx,
Object evt) |
void |
HttpServerKeepAliveHandler.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise) |
void |
HttpClientUpgradeHandler.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
void |
CorsHandler.channelRead(ChannelHandlerContext ctx,
Object msg) |
void |
CorsHandler.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
HttpContent |
HttpPostRequestEncoder.readChunk(ChannelHandlerContext ctx)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
Utf8FrameValidator.channelRead(ChannelHandlerContext ctx,
Object msg) |
protected void |
WebSocket08FrameDecoder.checkCloseFrameBody(ChannelHandlerContext ctx,
ByteBuf buffer) |
protected void |
WebSocket08FrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
WebSocket00FrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
WebSocketServerProtocolHandler.decode(ChannelHandlerContext ctx,
WebSocketFrame frame,
List<Object> out) |
protected void |
WebSocketClientProtocolHandler.decode(ChannelHandlerContext ctx,
WebSocketFrame frame,
List<Object> out) |
protected void |
WebSocket08FrameEncoder.encode(ChannelHandlerContext ctx,
WebSocketFrame msg,
List<Object> out) |
protected void |
WebSocket00FrameEncoder.encode(ChannelHandlerContext ctx,
WebSocketFrame msg,
List<Object> out) |
void |
WebSocketServerProtocolHandler.exceptionCaught(ChannelHandlerContext ctx,
Throwable cause) |
void |
WebSocketServerProtocolHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
WebSocketClientProtocolHandler.handlerAdded(ChannelHandlerContext ctx) |
WebSocketFrame |
WebSocketChunkedInput.readChunk(ChannelHandlerContext ctx)
Deprecated.
Use
WebSocketChunkedInput.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 WebSocketChunkedInput.isEndOfInput()
call must return true . |
Modifier and Type | Method and Description |
---|---|
void |
WebSocketServerExtensionHandler.channelRead(ChannelHandlerContext ctx,
Object msg) |
void |
WebSocketClientExtensionHandler.channelRead(ChannelHandlerContext ctx,
Object msg) |
void |
WebSocketServerExtensionHandler.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise) |
void |
WebSocketClientExtensionHandler.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
ChannelHandlerContext |
Http2RemoteFlowController.channelHandlerContext()
Get the
ChannelHandlerContext for which to apply flow control on. |
ChannelHandlerContext |
DefaultHttp2RemoteFlowController.channelHandlerContext() |
Modifier and Type | Method and Description |
---|---|
void |
Http2ConnectionHandler.bind(ChannelHandlerContext ctx,
SocketAddress localAddress,
ChannelPromise promise) |
void |
Http2ConnectionHandler.channelActive(ChannelHandlerContext ctx) |
void |
Http2FlowController.channelHandlerContext(ChannelHandlerContext ctx)
Set the
ChannelHandlerContext for which to apply flow control on. |
void |
DefaultHttp2RemoteFlowController.channelHandlerContext(ChannelHandlerContext ctx)
Set the
ChannelHandlerContext for which to apply flow control on. |
void |
DefaultHttp2LocalFlowController.channelHandlerContext(ChannelHandlerContext ctx) |
void |
Http2ConnectionHandler.channelInactive(ChannelHandlerContext ctx) |
void |
InboundHttpToHttp2Adapter.channelRead(ChannelHandlerContext ctx,
Object msg) |
void |
Http2MultiplexCodec.channelRead(ChannelHandlerContext ctx,
Object msg) |
void |
Http2MultiplexCodec.channelReadComplete(ChannelHandlerContext ctx)
Notifies any child streams of the read completion.
|
void |
Http2ConnectionHandler.channelReadComplete(ChannelHandlerContext ctx) |
void |
Http2ConnectionHandler.channelWritabilityChanged(ChannelHandlerContext ctx) |
void |
Http2ConnectionHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
Http2ConnectionHandler.connect(ChannelHandlerContext ctx,
SocketAddress remoteAddress,
SocketAddress localAddress,
ChannelPromise promise) |
protected void |
Http2ConnectionHandler.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
Http2ServerDowngrader.decode(ChannelHandlerContext ctx,
Http2StreamFrame frame,
List<Object> out) |
void |
Http2ConnectionDecoder.decodeFrame(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out)
Called by the
Http2ConnectionHandler to decode the next frame from the input buffer. |
void |
DefaultHttp2ConnectionDecoder.decodeFrame(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
void |
DecoratingHttp2ConnectionDecoder.decodeFrame(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
void |
Http2ConnectionHandler.deregister(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
Http2ConnectionHandler.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise) |
protected void |
Http2ServerDowngrader.encode(ChannelHandlerContext ctx,
HttpObject obj,
List<Object> out) |
void |
Http2RemoteFlowController.FlowControlled.error(ChannelHandlerContext ctx,
Throwable cause)
Called to indicate that an error occurred before this object could be completely written.
|
void |
Http2MultiplexCodec.exceptionCaught(ChannelHandlerContext ctx,
Throwable cause) |
void |
Http2FrameCodec.exceptionCaught(ChannelHandlerContext ctx,
Throwable cause) |
void |
Http2ConnectionHandler.exceptionCaught(ChannelHandlerContext ctx,
Throwable cause)
Handles
Http2Exception objects that were thrown from other handlers. |
protected void |
InboundHttp2ToHttpAdapter.fireChannelRead(ChannelHandlerContext ctx,
FullHttpMessage msg,
boolean release,
Http2Stream stream)
Set final headers and fire a channel read event
|
void |
Http2MultiplexCodec.flush(ChannelHandlerContext ctx) |
void |
Http2ConnectionHandler.flush(ChannelHandlerContext ctx) |
ChannelFuture |
Http2LifecycleManager.goAway(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData,
ChannelPromise promise)
Prevents the peer from creating streams and close the connection if
errorCode is not
Http2Error.NO_ERROR . |
ChannelFuture |
Http2ConnectionHandler.goAway(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData,
ChannelPromise promise) |
void |
Http2MultiplexCodec.handlerAdded(ChannelHandlerContext ctx) |
void |
Http2FrameCodec.handlerAdded(ChannelHandlerContext ctx)
Load any dependencies.
|
void |
Http2ConnectionHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
Http2Codec.handlerAdded(ChannelHandlerContext ctx) |
void |
CleartextHttp2ServerUpgradeHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
Http2FrameCodec.handlerRemoved(ChannelHandlerContext ctx)
Clean up any dependencies.
|
protected void |
Http2ConnectionHandler.handlerRemoved0(ChannelHandlerContext ctx) |
protected void |
Http2ConnectionHandler.handleServerHeaderDecodeSizeError(ChannelHandlerContext ctx,
Http2Stream stream)
Notifies client that this server has received headers that are larger than what it is
willing to accept.
|
boolean |
Http2PromisedRequestVerifier.isAuthoritative(ChannelHandlerContext ctx,
Http2Headers headers)
Determine if a
Http2Headers are authoritative for a particular ChannelHandlerContext . |
void |
Http2FrameLogger.logData(Http2FrameLogger.Direction direction,
ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endStream) |
void |
Http2FrameLogger.logGoAway(Http2FrameLogger.Direction direction,
ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData) |
void |
Http2FrameLogger.logHeaders(Http2FrameLogger.Direction direction,
ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int padding,
boolean endStream) |
void |
Http2FrameLogger.logHeaders(Http2FrameLogger.Direction direction,
ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int streamDependency,
short weight,
boolean exclusive,
int padding,
boolean endStream) |
void |
Http2FrameLogger.logPing(Http2FrameLogger.Direction direction,
ChannelHandlerContext ctx,
ByteBuf data) |
void |
Http2FrameLogger.logPingAck(Http2FrameLogger.Direction direction,
ChannelHandlerContext ctx,
ByteBuf data) |
void |
Http2FrameLogger.logPriority(Http2FrameLogger.Direction direction,
ChannelHandlerContext ctx,
int streamId,
int streamDependency,
short weight,
boolean exclusive) |
void |
Http2FrameLogger.logPushPromise(Http2FrameLogger.Direction direction,
ChannelHandlerContext ctx,
int streamId,
int promisedStreamId,
Http2Headers headers,
int padding) |
void |
Http2FrameLogger.logRstStream(Http2FrameLogger.Direction direction,
ChannelHandlerContext ctx,
int streamId,
long errorCode) |
void |
Http2FrameLogger.logSettings(Http2FrameLogger.Direction direction,
ChannelHandlerContext ctx,
Http2Settings settings) |
void |
Http2FrameLogger.logSettingsAck(Http2FrameLogger.Direction direction,
ChannelHandlerContext ctx) |
void |
Http2FrameLogger.logUnknownFrame(Http2FrameLogger.Direction direction,
ChannelHandlerContext ctx,
byte frameType,
int streamId,
Http2Flags flags,
ByteBuf data) |
void |
Http2FrameLogger.logWindowsUpdate(Http2FrameLogger.Direction direction,
ChannelHandlerContext ctx,
int streamId,
int windowSizeIncrement) |
boolean |
Http2RemoteFlowController.FlowControlled.merge(ChannelHandlerContext ctx,
Http2RemoteFlowController.FlowControlled next)
Merge the contents of the
next message into this message so they can be written out as one unit. |
protected EmbeddedChannel |
CompressorHttp2ConnectionEncoder.newContentCompressor(ChannelHandlerContext ctx,
CharSequence contentEncoding)
Returns a new
EmbeddedChannel that encodes the HTTP2 message content encoded in the specified
contentEncoding . |
protected EmbeddedChannel |
DelegatingDecompressorFrameListener.newContentDecompressor(ChannelHandlerContext ctx,
CharSequence contentEncoding)
Returns a new
EmbeddedChannel that decodes the HTTP2 message content encoded in the specified
contentEncoding . |
protected void |
Http2ConnectionHandler.onConnectionError(ChannelHandlerContext ctx,
Throwable cause,
Http2Exception http2Ex)
Handler for a connection error.
|
int |
InboundHttp2ToHttpAdapter.onDataRead(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endOfStream) |
int |
Http2FrameListenerDecorator.onDataRead(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endOfStream) |
int |
Http2FrameListener.onDataRead(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endOfStream)
Handles an inbound
DATA frame. |
int |
Http2FrameAdapter.onDataRead(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endOfStream) |
int |
Http2EventAdapter.onDataRead(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endOfStream) |
int |
DelegatingDecompressorFrameListener.onDataRead(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endOfStream) |
void |
Http2LifecycleManager.onError(ChannelHandlerContext ctx,
Throwable cause)
Processes the given error.
|
void |
Http2ConnectionHandler.onError(ChannelHandlerContext ctx,
Throwable cause)
Central handler for all exceptions caught during HTTP/2 processing.
|
void |
Http2FrameListenerDecorator.onGoAwayRead(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData) |
void |
Http2FrameListener.onGoAwayRead(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData)
Handles an inbound
GO_AWAY frame. |
void |
Http2FrameAdapter.onGoAwayRead(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData) |
void |
Http2EventAdapter.onGoAwayRead(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData) |
void |
InboundHttp2ToHttpAdapter.onHeadersRead(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int padding,
boolean endOfStream) |
void |
Http2FrameListenerDecorator.onHeadersRead(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int padding,
boolean endStream) |
void |
Http2FrameListener.onHeadersRead(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int padding,
boolean endOfStream)
Handles an inbound
HEADERS frame. |
void |
Http2FrameAdapter.onHeadersRead(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int padding,
boolean endStream) |
void |
Http2EventAdapter.onHeadersRead(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int padding,
boolean endStream) |
void |
DelegatingDecompressorFrameListener.onHeadersRead(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int padding,
boolean endStream) |
void |
InboundHttp2ToHttpAdapter.onHeadersRead(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int streamDependency,
short weight,
boolean exclusive,
int padding,
boolean endOfStream) |
void |
Http2FrameListenerDecorator.onHeadersRead(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int streamDependency,
short weight,
boolean exclusive,
int padding,
boolean endStream) |
void |
Http2FrameListener.onHeadersRead(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int streamDependency,
short weight,
boolean exclusive,
int padding,
boolean endOfStream)
Handles an inbound
HEADERS frame with priority information specified. |
void |
Http2FrameAdapter.onHeadersRead(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int streamDependency,
short weight,
boolean exclusive,
int padding,
boolean endStream) |
void |
Http2EventAdapter.onHeadersRead(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int streamDependency,
short weight,
boolean exclusive,
int padding,
boolean endStream) |
void |
DelegatingDecompressorFrameListener.onHeadersRead(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int streamDependency,
short weight,
boolean exclusive,
int padding,
boolean endStream) |
void |
Http2FrameListenerDecorator.onPingAckRead(ChannelHandlerContext ctx,
ByteBuf data) |
void |
Http2FrameListener.onPingAckRead(ChannelHandlerContext ctx,
ByteBuf data)
Handles an inbound
PING acknowledgment. |
void |
Http2FrameAdapter.onPingAckRead(ChannelHandlerContext ctx,
ByteBuf data) |
void |
Http2EventAdapter.onPingAckRead(ChannelHandlerContext ctx,
ByteBuf data) |
void |
Http2FrameListenerDecorator.onPingRead(ChannelHandlerContext ctx,
ByteBuf data) |
void |
Http2FrameListener.onPingRead(ChannelHandlerContext ctx,
ByteBuf data)
Handles an inbound
PING frame. |
void |
Http2FrameAdapter.onPingRead(ChannelHandlerContext ctx,
ByteBuf data) |
void |
Http2EventAdapter.onPingRead(ChannelHandlerContext ctx,
ByteBuf data) |
void |
Http2FrameListenerDecorator.onPriorityRead(ChannelHandlerContext ctx,
int streamId,
int streamDependency,
short weight,
boolean exclusive) |
void |
Http2FrameListener.onPriorityRead(ChannelHandlerContext ctx,
int streamId,
int streamDependency,
short weight,
boolean exclusive)
Handles an inbound
PRIORITY frame. |
void |
Http2FrameAdapter.onPriorityRead(ChannelHandlerContext ctx,
int streamId,
int streamDependency,
short weight,
boolean exclusive) |
void |
Http2EventAdapter.onPriorityRead(ChannelHandlerContext ctx,
int streamId,
int streamDependency,
short weight,
boolean exclusive) |
void |
InboundHttp2ToHttpAdapter.onPushPromiseRead(ChannelHandlerContext ctx,
int streamId,
int promisedStreamId,
Http2Headers headers,
int padding) |
void |
Http2FrameListenerDecorator.onPushPromiseRead(ChannelHandlerContext ctx,
int streamId,
int promisedStreamId,
Http2Headers headers,
int padding) |
void |
Http2FrameListener.onPushPromiseRead(ChannelHandlerContext ctx,
int streamId,
int promisedStreamId,
Http2Headers headers,
int padding)
Handles an inbound
PUSH_PROMISE frame. |
void |
Http2FrameAdapter.onPushPromiseRead(ChannelHandlerContext ctx,
int streamId,
int promisedStreamId,
Http2Headers headers,
int padding) |
void |
Http2EventAdapter.onPushPromiseRead(ChannelHandlerContext ctx,
int streamId,
int promisedStreamId,
Http2Headers headers,
int padding) |
void |
InboundHttp2ToHttpAdapter.onRstStreamRead(ChannelHandlerContext ctx,
int streamId,
long errorCode) |
void |
Http2FrameListenerDecorator.onRstStreamRead(ChannelHandlerContext ctx,
int streamId,
long errorCode) |
void |
Http2FrameListener.onRstStreamRead(ChannelHandlerContext ctx,
int streamId,
long errorCode)
Handles an inbound
RST_STREAM frame. |
void |
Http2FrameAdapter.onRstStreamRead(ChannelHandlerContext ctx,
int streamId,
long errorCode) |
void |
Http2EventAdapter.onRstStreamRead(ChannelHandlerContext ctx,
int streamId,
long errorCode) |
void |
Http2FrameListenerDecorator.onSettingsAckRead(ChannelHandlerContext ctx) |
void |
Http2FrameListener.onSettingsAckRead(ChannelHandlerContext ctx)
Handles an inbound
SETTINGS acknowledgment frame. |
void |
Http2FrameAdapter.onSettingsAckRead(ChannelHandlerContext ctx) |
void |
Http2EventAdapter.onSettingsAckRead(ChannelHandlerContext ctx) |
void |
InboundHttp2ToHttpAdapter.onSettingsRead(ChannelHandlerContext ctx,
Http2Settings settings) |
void |
Http2FrameListenerDecorator.onSettingsRead(ChannelHandlerContext ctx,
Http2Settings settings) |
void |
Http2FrameListener.onSettingsRead(ChannelHandlerContext ctx,
Http2Settings settings)
Handles an inbound
SETTINGS frame. |
void |
Http2FrameAdapter.onSettingsRead(ChannelHandlerContext ctx,
Http2Settings settings) |
void |
Http2EventAdapter.onSettingsRead(ChannelHandlerContext ctx,
Http2Settings settings) |
protected void |
Http2ConnectionHandler.onStreamError(ChannelHandlerContext ctx,
Throwable cause,
Http2Exception.StreamException http2Ex)
Handler for a stream error.
|
void |
Http2FrameListenerDecorator.onUnknownFrame(ChannelHandlerContext ctx,
byte frameType,
int streamId,
Http2Flags flags,
ByteBuf payload) |
void |
Http2FrameListener.onUnknownFrame(ChannelHandlerContext ctx,
byte frameType,
int streamId,
Http2Flags flags,
ByteBuf payload)
Handler for a frame not defined by the HTTP/2 spec.
|
void |
Http2FrameAdapter.onUnknownFrame(ChannelHandlerContext ctx,
byte frameType,
int streamId,
Http2Flags flags,
ByteBuf payload) |
void |
Http2EventAdapter.onUnknownFrame(ChannelHandlerContext ctx,
byte frameType,
int streamId,
Http2Flags flags,
ByteBuf payload) |
void |
Http2FrameListenerDecorator.onWindowUpdateRead(ChannelHandlerContext ctx,
int streamId,
int windowSizeIncrement) |
void |
Http2FrameListener.onWindowUpdateRead(ChannelHandlerContext ctx,
int streamId,
int windowSizeIncrement)
Handles an inbound
WINDOW_UPDATE frame. |
void |
Http2FrameAdapter.onWindowUpdateRead(ChannelHandlerContext ctx,
int streamId,
int windowSizeIncrement) |
void |
Http2EventAdapter.onWindowUpdateRead(ChannelHandlerContext ctx,
int streamId,
int windowSizeIncrement) |
boolean |
Http2ServerUpgradeCodec.prepareUpgradeResponse(ChannelHandlerContext ctx,
FullHttpRequest upgradeRequest,
HttpHeaders headers) |
protected FullHttpMessage |
InboundHttp2ToHttpAdapter.processHeadersBegin(ChannelHandlerContext ctx,
Http2Stream stream,
Http2Headers headers,
boolean endOfStream,
boolean allowAppend,
boolean appendToTrailer)
Provides translation between HTTP/2 and HTTP header objects while ensuring the stream
is in a valid state for additional headers.
|
void |
Http2ConnectionHandler.read(ChannelHandlerContext ctx) |
void |
Http2InboundFrameLogger.readFrame(ChannelHandlerContext ctx,
ByteBuf input,
Http2FrameListener listener) |
void |
Http2FrameReader.readFrame(ChannelHandlerContext ctx,
ByteBuf input,
Http2FrameListener listener)
Attempts to read the next frame from the input buffer.
|
void |
DefaultHttp2FrameReader.readFrame(ChannelHandlerContext ctx,
ByteBuf input,
Http2FrameListener listener) |
ChannelFuture |
Http2LifecycleManager.resetStream(ChannelHandlerContext ctx,
int streamId,
long errorCode,
ChannelPromise promise)
Ensure the stream identified by
streamId is reset. |
ChannelFuture |
Http2ConnectionHandler.resetStream(ChannelHandlerContext ctx,
int streamId,
long errorCode,
ChannelPromise promise) |
Collection<CharSequence> |
Http2ClientUpgradeCodec.setUpgradeHeaders(ChannelHandlerContext ctx,
HttpRequest upgradeRequest) |
static ByteBuf |
Http2CodecUtil.toByteBuf(ChannelHandlerContext ctx,
Throwable cause)
Creates a buffer containing the error message from the given exception.
|
void |
Http2ServerUpgradeCodec.upgradeTo(ChannelHandlerContext ctx,
FullHttpRequest upgradeRequest) |
void |
Http2ClientUpgradeCodec.upgradeTo(ChannelHandlerContext ctx,
FullHttpResponse upgradeResponse) |
void |
Http2MultiplexCodec.userEventTriggered(ChannelHandlerContext ctx,
Object evt) |
void |
Http2FrameCodec.userEventTriggered(ChannelHandlerContext ctx,
Object evt)
Handles the cleartext HTTP upgrade event.
|
void |
Http2RemoteFlowController.FlowControlled.write(ChannelHandlerContext ctx,
int allowedBytes)
Writes up to
allowedBytes of the encapsulated payload to the stream. |
void |
HttpToHttp2ConnectionHandler.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise)
Handles conversion of
HttpMessage and HttpContent to HTTP/2 frames. |
void |
Http2FrameCodec.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise)
Processes all
Http2Frame s. |
void |
Http2ConnectionHandler.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise) |
ChannelFuture |
StreamBufferingEncoder.writeData(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endOfStream,
ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writeData(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endStream,
ChannelPromise promise) |
ChannelFuture |
Http2DataWriter.writeData(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endStream,
ChannelPromise promise)
Writes a
DATA frame to the remote endpoint. |
ChannelFuture |
DefaultHttp2FrameWriter.writeData(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endStream,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writeData(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endOfStream,
ChannelPromise promise) |
ChannelFuture |
DecoratingHttp2FrameWriter.writeData(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endStream,
ChannelPromise promise) |
ChannelFuture |
CompressorHttp2ConnectionEncoder.writeData(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endOfStream,
ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writeFrame(ChannelHandlerContext ctx,
byte frameType,
int streamId,
Http2Flags flags,
ByteBuf payload,
ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writeFrame(ChannelHandlerContext ctx,
byte frameType,
int streamId,
Http2Flags flags,
ByteBuf payload,
ChannelPromise promise)
Generic write method for any HTTP/2 frame.
|
ChannelFuture |
Http2ConnectionEncoder.writeFrame(ChannelHandlerContext ctx,
byte frameType,
int streamId,
Http2Flags flags,
ByteBuf payload,
ChannelPromise promise)
Writes the given data to the internal
Http2FrameWriter without performing any
state checks on the connection/stream. |
ChannelFuture |
DefaultHttp2FrameWriter.writeFrame(ChannelHandlerContext ctx,
byte frameType,
int streamId,
Http2Flags flags,
ByteBuf payload,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writeFrame(ChannelHandlerContext ctx,
byte frameType,
int streamId,
Http2Flags flags,
ByteBuf payload,
ChannelPromise promise) |
ChannelFuture |
DecoratingHttp2FrameWriter.writeFrame(ChannelHandlerContext ctx,
byte frameType,
int streamId,
Http2Flags flags,
ByteBuf payload,
ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writeGoAway(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData,
ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writeGoAway(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData,
ChannelPromise promise)
Writes a GO_AWAY frame to the remote endpoint.
|
ChannelFuture |
DefaultHttp2FrameWriter.writeGoAway(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writeGoAway(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData,
ChannelPromise promise) |
ChannelFuture |
DecoratingHttp2FrameWriter.writeGoAway(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData,
ChannelPromise promise) |
ChannelFuture |
StreamBufferingEncoder.writeHeaders(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int padding,
boolean endStream,
ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writeHeaders(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int padding,
boolean endStream,
ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writeHeaders(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int padding,
boolean endStream,
ChannelPromise promise)
Writes a HEADERS frame to the remote endpoint.
|
ChannelFuture |
DefaultHttp2FrameWriter.writeHeaders(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int padding,
boolean endStream,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writeHeaders(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int padding,
boolean endStream,
ChannelPromise promise) |
ChannelFuture |
DecoratingHttp2FrameWriter.writeHeaders(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int padding,
boolean endStream,
ChannelPromise promise) |
ChannelFuture |
CompressorHttp2ConnectionEncoder.writeHeaders(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int padding,
boolean endStream,
ChannelPromise promise) |
ChannelFuture |
StreamBufferingEncoder.writeHeaders(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int streamDependency,
short weight,
boolean exclusive,
int padding,
boolean endOfStream,
ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writeHeaders(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int streamDependency,
short weight,
boolean exclusive,
int padding,
boolean endStream,
ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writeHeaders(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int streamDependency,
short weight,
boolean exclusive,
int padding,
boolean endStream,
ChannelPromise promise)
Writes a HEADERS frame with priority specified to the remote endpoint.
|
ChannelFuture |
DefaultHttp2FrameWriter.writeHeaders(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int streamDependency,
short weight,
boolean exclusive,
int padding,
boolean endStream,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writeHeaders(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int streamDependency,
short weight,
boolean exclusive,
int padding,
boolean endOfStream,
ChannelPromise promise) |
ChannelFuture |
DecoratingHttp2FrameWriter.writeHeaders(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int streamDependency,
short weight,
boolean exclusive,
int padding,
boolean endStream,
ChannelPromise promise) |
ChannelFuture |
CompressorHttp2ConnectionEncoder.writeHeaders(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int streamDependency,
short weight,
boolean exclusive,
int padding,
boolean endOfStream,
ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writePing(ChannelHandlerContext ctx,
boolean ack,
ByteBuf data,
ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writePing(ChannelHandlerContext ctx,
boolean ack,
ByteBuf data,
ChannelPromise promise)
Writes a PING frame to the remote endpoint.
|
ChannelFuture |
DefaultHttp2FrameWriter.writePing(ChannelHandlerContext ctx,
boolean ack,
ByteBuf data,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writePing(ChannelHandlerContext ctx,
boolean ack,
ByteBuf data,
ChannelPromise promise) |
ChannelFuture |
DecoratingHttp2FrameWriter.writePing(ChannelHandlerContext ctx,
boolean ack,
ByteBuf data,
ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writePriority(ChannelHandlerContext ctx,
int streamId,
int streamDependency,
short weight,
boolean exclusive,
ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writePriority(ChannelHandlerContext ctx,
int streamId,
int streamDependency,
short weight,
boolean exclusive,
ChannelPromise promise)
Writes a PRIORITY frame to the remote endpoint.
|
ChannelFuture |
DefaultHttp2FrameWriter.writePriority(ChannelHandlerContext ctx,
int streamId,
int streamDependency,
short weight,
boolean exclusive,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writePriority(ChannelHandlerContext ctx,
int streamId,
int streamDependency,
short weight,
boolean exclusive,
ChannelPromise promise) |
ChannelFuture |
DecoratingHttp2FrameWriter.writePriority(ChannelHandlerContext ctx,
int streamId,
int streamDependency,
short weight,
boolean exclusive,
ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writePushPromise(ChannelHandlerContext ctx,
int streamId,
int promisedStreamId,
Http2Headers headers,
int padding,
ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writePushPromise(ChannelHandlerContext ctx,
int streamId,
int promisedStreamId,
Http2Headers headers,
int padding,
ChannelPromise promise)
Writes a PUSH_PROMISE frame to the remote endpoint.
|
ChannelFuture |
DefaultHttp2FrameWriter.writePushPromise(ChannelHandlerContext ctx,
int streamId,
int promisedStreamId,
Http2Headers headers,
int padding,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writePushPromise(ChannelHandlerContext ctx,
int streamId,
int promisedStreamId,
Http2Headers headers,
int padding,
ChannelPromise promise) |
ChannelFuture |
DecoratingHttp2FrameWriter.writePushPromise(ChannelHandlerContext ctx,
int streamId,
int promisedStreamId,
Http2Headers headers,
int padding,
ChannelPromise promise) |
ChannelFuture |
StreamBufferingEncoder.writeRstStream(ChannelHandlerContext ctx,
int streamId,
long errorCode,
ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writeRstStream(ChannelHandlerContext ctx,
int streamId,
long errorCode,
ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writeRstStream(ChannelHandlerContext ctx,
int streamId,
long errorCode,
ChannelPromise promise)
Writes a RST_STREAM frame to the remote endpoint.
|
ChannelFuture |
DefaultHttp2FrameWriter.writeRstStream(ChannelHandlerContext ctx,
int streamId,
long errorCode,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writeRstStream(ChannelHandlerContext ctx,
int streamId,
long errorCode,
ChannelPromise promise) |
ChannelFuture |
DecoratingHttp2FrameWriter.writeRstStream(ChannelHandlerContext ctx,
int streamId,
long errorCode,
ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writeSettings(ChannelHandlerContext ctx,
Http2Settings settings,
ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writeSettings(ChannelHandlerContext ctx,
Http2Settings settings,
ChannelPromise promise)
Writes a SETTINGS frame to the remote endpoint.
|
ChannelFuture |
DefaultHttp2FrameWriter.writeSettings(ChannelHandlerContext ctx,
Http2Settings settings,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writeSettings(ChannelHandlerContext ctx,
Http2Settings settings,
ChannelPromise promise) |
ChannelFuture |
DecoratingHttp2FrameWriter.writeSettings(ChannelHandlerContext ctx,
Http2Settings settings,
ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writeSettingsAck(ChannelHandlerContext ctx,
ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writeSettingsAck(ChannelHandlerContext ctx,
ChannelPromise promise)
Writes a SETTINGS acknowledgment to the remote endpoint.
|
ChannelFuture |
DefaultHttp2FrameWriter.writeSettingsAck(ChannelHandlerContext ctx,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writeSettingsAck(ChannelHandlerContext ctx,
ChannelPromise promise) |
ChannelFuture |
DecoratingHttp2FrameWriter.writeSettingsAck(ChannelHandlerContext ctx,
ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writeWindowUpdate(ChannelHandlerContext ctx,
int streamId,
int windowSizeIncrement,
ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writeWindowUpdate(ChannelHandlerContext ctx,
int streamId,
int windowSizeIncrement,
ChannelPromise promise)
Writes a WINDOW_UPDATE frame to the remote endpoint.
|
ChannelFuture |
DefaultHttp2FrameWriter.writeWindowUpdate(ChannelHandlerContext ctx,
int streamId,
int windowSizeIncrement,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writeWindowUpdate(ChannelHandlerContext ctx,
int streamId,
int windowSizeIncrement,
ChannelPromise promise) |
ChannelFuture |
DecoratingHttp2FrameWriter.writeWindowUpdate(ChannelHandlerContext ctx,
int streamId,
int windowSizeIncrement,
ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
protected void |
JsonObjectDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<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 Object |
MarshallingDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in) |
protected void |
CompatibleMarshallingDecoder.decode(ChannelHandlerContext ctx,
ByteBuf buffer,
List<Object> out) |
protected void |
CompatibleMarshallingDecoder.decodeLast(ChannelHandlerContext ctx,
ByteBuf buffer,
List<Object> out) |
protected void |
MarshallingEncoder.encode(ChannelHandlerContext ctx,
Object msg,
ByteBuf out) |
protected void |
CompatibleMarshallingEncoder.encode(ChannelHandlerContext ctx,
Object msg,
ByteBuf out) |
void |
CompatibleMarshallingDecoder.exceptionCaught(ChannelHandlerContext ctx,
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 |
AbstractMemcacheObjectEncoder.encode(ChannelHandlerContext ctx,
Object msg,
List<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.
|
protected void |
AbstractBinaryMemcacheDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected ByteBuf |
AbstractBinaryMemcacheEncoder.encodeMessage(ChannelHandlerContext ctx,
M msg) |
Modifier and Type | Method and Description |
---|---|
protected void |
MqttDecoder.decode(ChannelHandlerContext ctx,
ByteBuf buffer,
List<Object> out) |
protected void |
MqttEncoder.encode(ChannelHandlerContext ctx,
MqttMessage msg,
List<Object> out) |
Modifier and Type | Method and Description |
---|---|
protected void |
ProtobufVarint32FrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
ProtobufDecoderNano.decode(ChannelHandlerContext ctx,
ByteBuf msg,
List<Object> out) |
protected void |
ProtobufDecoder.decode(ChannelHandlerContext ctx,
ByteBuf msg,
List<Object> out) |
protected void |
ProtobufVarint32LengthFieldPrepender.encode(ChannelHandlerContext ctx,
ByteBuf msg,
ByteBuf out) |
protected void |
ProtobufEncoder.encode(ChannelHandlerContext ctx,
com.google.protobuf.MessageLiteOrBuilder msg,
List<Object> out) |
protected void |
ProtobufEncoderNano.encode(ChannelHandlerContext ctx,
MessageNano msg,
List<Object> out) |
Modifier and Type | Method and Description |
---|---|
protected void |
RedisDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
RedisArrayAggregator.decode(ChannelHandlerContext ctx,
RedisMessage msg,
List<Object> out) |
protected void |
RedisEncoder.encode(ChannelHandlerContext ctx,
RedisMessage msg,
List<Object> out) |
Modifier and Type | Method and Description |
---|---|
protected void |
SctpMessageCompletionHandler.decode(ChannelHandlerContext ctx,
SctpMessage msg,
List<Object> out) |
protected void |
SctpInboundByteStreamHandler.decode(ChannelHandlerContext ctx,
SctpMessage msg,
List<Object> out) |
protected void |
SctpOutboundByteStreamHandler.encode(ChannelHandlerContext ctx,
ByteBuf msg,
List<Object> out) |
Modifier and Type | Method and Description |
---|---|
protected Object |
ObjectDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in) |
protected void |
ObjectEncoder.encode(ChannelHandlerContext ctx,
Serializable msg,
ByteBuf out) |
protected void |
CompatibleObjectEncoder.encode(ChannelHandlerContext ctx,
Serializable msg,
ByteBuf out) |
Modifier and Type | Method and Description |
---|---|
protected SmtpResponse |
SmtpResponseDecoder.decode(ChannelHandlerContext ctx,
ByteBuf buffer) |
protected void |
SmtpRequestEncoder.encode(ChannelHandlerContext ctx,
Object msg,
List<Object> out) |
Modifier and Type | Method and Description |
---|---|
protected void |
SocksInitResponseDecoder.decode(ChannelHandlerContext ctx,
ByteBuf byteBuf,
List<Object> out) |
protected void |
SocksInitRequestDecoder.decode(ChannelHandlerContext ctx,
ByteBuf byteBuf,
List<Object> out) |
protected void |
SocksCmdResponseDecoder.decode(ChannelHandlerContext ctx,
ByteBuf byteBuf,
List<Object> out) |
protected void |
SocksCmdRequestDecoder.decode(ChannelHandlerContext ctx,
ByteBuf byteBuf,
List<Object> out) |
protected void |
SocksAuthResponseDecoder.decode(ChannelHandlerContext channelHandlerContext,
ByteBuf byteBuf,
List<Object> out) |
protected void |
SocksAuthRequestDecoder.decode(ChannelHandlerContext ctx,
ByteBuf byteBuf,
List<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,
List<Object> out) |
Modifier and Type | Method and Description |
---|---|
protected void |
Socks4ServerDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
Socks4ClientDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<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 |
Socks5PasswordAuthResponseDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
Socks5PasswordAuthRequestDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
Socks5InitialResponseDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
Socks5InitialRequestDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
Socks5CommandResponseDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
Socks5CommandRequestDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
Socks5ServerEncoder.encode(ChannelHandlerContext ctx,
Socks5Message msg,
ByteBuf out) |
protected void |
Socks5ClientEncoder.encode(ChannelHandlerContext ctx,
Socks5Message msg,
ByteBuf out) |
Modifier and Type | Method and Description |
---|---|
void |
SpdyFrameCodec.bind(ChannelHandlerContext ctx,
SocketAddress localAddress,
ChannelPromise promise) |
void |
SpdySessionHandler.channelInactive(ChannelHandlerContext ctx) |
void |
SpdyHttpDecoder.channelInactive(ChannelHandlerContext ctx) |
void |
SpdySessionHandler.channelRead(ChannelHandlerContext ctx,
Object msg) |
void |
SpdyFrameCodec.channelReadComplete(ChannelHandlerContext ctx) |
void |
SpdySessionHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
SpdyFrameCodec.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
SpdyFrameCodec.connect(ChannelHandlerContext ctx,
SocketAddress remoteAddress,
SocketAddress localAddress,
ChannelPromise promise) |
protected void |
SpdyFrameCodec.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
SpdyHttpResponseStreamIdHandler.decode(ChannelHandlerContext ctx,
Object msg,
List<Object> out) |
protected void |
SpdyHttpDecoder.decode(ChannelHandlerContext ctx,
SpdyFrame msg,
List<Object> out) |
void |
SpdyFrameCodec.deregister(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
SpdyFrameCodec.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise) |
protected void |
SpdyHttpResponseStreamIdHandler.encode(ChannelHandlerContext ctx,
HttpMessage msg,
List<Object> out) |
protected void |
SpdyHttpEncoder.encode(ChannelHandlerContext ctx,
HttpObject msg,
List<Object> out) |
void |
SpdySessionHandler.exceptionCaught(ChannelHandlerContext ctx,
Throwable cause) |
void |
SpdyFrameCodec.flush(ChannelHandlerContext ctx) |
void |
SpdyFrameCodec.handlerAdded(ChannelHandlerContext ctx) |
void |
SpdyFrameCodec.read(ChannelHandlerContext ctx) |
void |
SpdySessionHandler.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise) |
void |
SpdyFrameCodec.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
protected void |
StompSubframeDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
StompSubframeEncoder.encode(ChannelHandlerContext ctx,
StompSubframe msg,
List<Object> out) |
Modifier and Type | Method and Description |
---|---|
protected void |
StringDecoder.decode(ChannelHandlerContext ctx,
ByteBuf msg,
List<Object> out) |
protected void |
StringEncoder.encode(ChannelHandlerContext ctx,
CharSequence msg,
List<Object> out) |
protected void |
LineEncoder.encode(ChannelHandlerContext ctx,
CharSequence msg,
List<Object> out) |
Modifier and Type | Method and Description |
---|---|
protected void |
XmlDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
XmlFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
Modifier and Type | Method and Description |
---|---|
void |
FlowControlHandler.channelInactive(ChannelHandlerContext ctx) |
void |
FlowControlHandler.channelRead(ChannelHandlerContext ctx,
Object msg) |
void |
FlowControlHandler.channelReadComplete(ChannelHandlerContext ctx) |
void |
FlowControlHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
FlowControlHandler.read(ChannelHandlerContext ctx) |
Modifier and Type | Method and Description |
---|---|
void |
FlushConsolidationHandler.channelRead(ChannelHandlerContext ctx,
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,
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,
InetSocketAddress remoteAddress) |
protected boolean |
RuleBasedIpFilter.accept(ChannelHandlerContext ctx,
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,
SocketAddress localAddress,
ChannelPromise promise) |
void |
LoggingHandler.channelActive(ChannelHandlerContext ctx) |
void |
LoggingHandler.channelInactive(ChannelHandlerContext ctx) |
void |
LoggingHandler.channelRead(ChannelHandlerContext ctx,
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,
SocketAddress remoteAddress,
SocketAddress localAddress,
ChannelPromise promise) |
void |
LoggingHandler.deregister(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
LoggingHandler.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
LoggingHandler.exceptionCaught(ChannelHandlerContext ctx,
Throwable cause) |
void |
LoggingHandler.flush(ChannelHandlerContext ctx) |
protected String |
LoggingHandler.format(ChannelHandlerContext ctx,
String eventName)
Formats an event and returns the formatted message.
|
protected String |
LoggingHandler.format(ChannelHandlerContext ctx,
String eventName,
Object arg)
Formats an event and returns the formatted message.
|
protected String |
LoggingHandler.format(ChannelHandlerContext ctx,
String eventName,
Object firstArg,
Object secondArg)
Formats an event and returns the formatted message.
|
void |
LoggingHandler.userEventTriggered(ChannelHandlerContext ctx,
Object evt) |
void |
LoggingHandler.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
protected void |
Socks5ProxyHandler.addCodec(ChannelHandlerContext ctx) |
protected void |
Socks4ProxyHandler.addCodec(ChannelHandlerContext ctx) |
protected abstract void |
ProxyHandler.addCodec(ChannelHandlerContext ctx)
Adds the codec handlers required to communicate with the proxy server.
|
protected void |
HttpProxyHandler.addCodec(ChannelHandlerContext ctx) |
void |
ProxyHandler.channelActive(ChannelHandlerContext ctx) |
void |
ProxyHandler.channelInactive(ChannelHandlerContext ctx) |
void |
ProxyHandler.channelRead(ChannelHandlerContext ctx,
Object msg) |
void |
ProxyHandler.channelReadComplete(ChannelHandlerContext ctx) |
void |
ProxyHandler.connect(ChannelHandlerContext ctx,
SocketAddress remoteAddress,
SocketAddress localAddress,
ChannelPromise promise) |
void |
ProxyHandler.exceptionCaught(ChannelHandlerContext ctx,
Throwable cause) |
void |
ProxyHandler.flush(ChannelHandlerContext ctx) |
void |
ProxyHandler.handlerAdded(ChannelHandlerContext ctx) |
protected boolean |
Socks5ProxyHandler.handleResponse(ChannelHandlerContext ctx,
Object response) |
protected boolean |
Socks4ProxyHandler.handleResponse(ChannelHandlerContext ctx,
Object response) |
protected abstract boolean |
ProxyHandler.handleResponse(ChannelHandlerContext ctx,
Object response)
Handles the message received from the proxy server.
|
protected boolean |
HttpProxyHandler.handleResponse(ChannelHandlerContext ctx,
Object response) |
protected Object |
Socks5ProxyHandler.newInitialMessage(ChannelHandlerContext ctx) |
protected Object |
Socks4ProxyHandler.newInitialMessage(ChannelHandlerContext ctx) |
protected abstract Object |
ProxyHandler.newInitialMessage(ChannelHandlerContext ctx)
Returns a new message that is sent at first time when the connection to the proxy server has been established.
|
protected Object |
HttpProxyHandler.newInitialMessage(ChannelHandlerContext ctx) |
protected void |
Socks5ProxyHandler.removeDecoder(ChannelHandlerContext ctx) |
protected void |
Socks4ProxyHandler.removeDecoder(ChannelHandlerContext ctx) |
protected abstract void |
ProxyHandler.removeDecoder(ChannelHandlerContext ctx)
Removes the decoders added in
ProxyHandler.addCodec(ChannelHandlerContext) . |
protected void |
HttpProxyHandler.removeDecoder(ChannelHandlerContext ctx) |
protected void |
Socks5ProxyHandler.removeEncoder(ChannelHandlerContext ctx) |
protected void |
Socks4ProxyHandler.removeEncoder(ChannelHandlerContext ctx) |
protected abstract void |
ProxyHandler.removeEncoder(ChannelHandlerContext ctx)
Removes the encoders added in
ProxyHandler.addCodec(ChannelHandlerContext) . |
protected void |
HttpProxyHandler.removeEncoder(ChannelHandlerContext ctx) |
void |
ProxyHandler.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
void |
SslHandler.bind(ChannelHandlerContext ctx,
SocketAddress localAddress,
ChannelPromise promise) |
void |
AbstractSniHandler.bind(ChannelHandlerContext ctx,
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) |
void |
AbstractSniHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
protected abstract void |
ApplicationProtocolNegotiationHandler.configurePipeline(ChannelHandlerContext ctx,
String protocol)
Invoked on successful initial SSL/TLS handshake.
|
void |
SslHandler.connect(ChannelHandlerContext ctx,
SocketAddress remoteAddress,
SocketAddress localAddress,
ChannelPromise promise) |
void |
AbstractSniHandler.connect(ChannelHandlerContext ctx,
SocketAddress remoteAddress,
SocketAddress localAddress,
ChannelPromise promise) |
protected void |
SslHandler.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
OptionalSslHandler.decode(ChannelHandlerContext context,
ByteBuf in,
List<Object> out) |
protected void |
AbstractSniHandler.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
void |
SslHandler.deregister(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
AbstractSniHandler.deregister(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
SslHandler.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
AbstractSniHandler.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
SslHandler.exceptionCaught(ChannelHandlerContext ctx,
Throwable cause) |
void |
ApplicationProtocolNegotiationHandler.exceptionCaught(ChannelHandlerContext ctx,
Throwable cause) |
void |
SslHandler.flush(ChannelHandlerContext ctx) |
void |
AbstractSniHandler.flush(ChannelHandlerContext ctx) |
void |
SslHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
SslHandler.handlerRemoved0(ChannelHandlerContext ctx) |
protected void |
ApplicationProtocolNegotiationHandler.handshakeFailure(ChannelHandlerContext ctx,
Throwable cause)
Invoked on failed initial SSL/TLS handshake.
|
protected Future<SslContext> |
SniHandler.lookup(ChannelHandlerContext ctx,
String hostname)
The default implementation will simply call
AsyncMapping.map(Object, Promise) but
users can override this method to implement custom behavior. |
protected abstract Future<T> |
AbstractSniHandler.lookup(ChannelHandlerContext ctx,
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 ChannelHandler |
OptionalSslHandler.newNonSslHandler(ChannelHandlerContext context)
Override to configure the ChannelHandler.
|
protected SslHandler |
OptionalSslHandler.newSslHandler(ChannelHandlerContext context,
SslContext sslContext)
Override to configure the SslHandler eg.
|
protected void |
SniHandler.onLookupComplete(ChannelHandlerContext ctx,
String hostname,
Future<SslContext> future) |
protected abstract void |
AbstractSniHandler.onLookupComplete(ChannelHandlerContext ctx,
String hostname,
Future<T> future)
Called upon completion of the
AbstractSniHandler.lookup(ChannelHandlerContext, String) Future . |
void |
SslHandler.read(ChannelHandlerContext ctx) |
void |
AbstractSniHandler.read(ChannelHandlerContext ctx) |
protected void |
SniHandler.replaceHandler(ChannelHandlerContext ctx,
String hostname,
SslContext sslContext)
The default implementation of this method will simply replace
this SniHandler
instance with a SslHandler . |
void |
ApplicationProtocolNegotiationHandler.userEventTriggered(ChannelHandlerContext ctx,
Object evt) |
void |
SslHandler.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise) |
void |
AbstractSniHandler.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
void |
OcspClientHandler.userEventTriggered(ChannelHandlerContext ctx,
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)
Deprecated.
|
ByteBuf |
ChunkedNioStream.readChunk(ChannelHandlerContext ctx)
Deprecated.
|
ByteBuf |
ChunkedNioFile.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 |
ChunkedFile.readChunk(ChannelHandlerContext ctx)
Deprecated.
|
void |
ChunkedWriteHandler.write(ChannelHandlerContext ctx,
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,
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,
Object msg,
ChannelPromise promise) |
void |
IdleStateHandler.write(ChannelHandlerContext ctx,
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,
Object msg) |
void |
AbstractTrafficShapingHandler.channelRead(ChannelHandlerContext ctx,
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,
Object msg,
long delay,
ChannelPromise promise)
Deprecated.
|
protected void |
GlobalChannelTrafficShapingHandler.submitWrite(ChannelHandlerContext ctx,
Object msg,
long size,
long writedelay,
long now,
ChannelPromise promise) |
void |
GlobalChannelTrafficShapingHandler.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise) |
void |
AbstractTrafficShapingHandler.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise) |
Copyright © 2008–2017 The Netty Project. All rights reserved.