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.address |
Package to dynamically replace local / remote
SocketAddress . |
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 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 codec provides asynchronous and non-blocking XML parser based on the
Aalto XML parser.
|
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.pcap |
Capture data and write into Pcap format which helps in troubleshooting.
|
io.netty.handler.proxy |
Adds support for client connections via proxy protocols such as
SOCKS and
HTTP CONNECT tunneling
|
io.netty.handler.ssl | |
io.netty.handler.ssl.ocsp |
Certificate validation using OCSP
|
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 |
ChannelPipeline.context(ChannelHandler handler)
Returns the context object of the specified
ChannelHandler in
this pipeline. |
ChannelHandlerContext |
DefaultChannelPipeline.context(ChannelHandler handler) |
ChannelHandlerContext |
ChannelPipeline.context(Class<? extends ChannelHandler> handlerType)
Returns the context object of the
ChannelHandler of the
specified type in this pipeline. |
ChannelHandlerContext |
DefaultChannelPipeline.context(Class<? extends ChannelHandler> handlerType) |
ChannelHandlerContext |
ChannelPipeline.context(String name)
Returns the context object of the
ChannelHandler with the
specified name in this pipeline. |
ChannelHandlerContext |
DefaultChannelPipeline.context(String name) |
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 |
ChannelPipeline.firstContext()
Returns the context of the first
ChannelHandler in this pipeline. |
ChannelHandlerContext |
DefaultChannelPipeline.firstContext() |
ChannelHandlerContext |
ChannelHandlerContext.flush() |
ChannelHandlerContext |
ChannelPipeline.lastContext()
Returns the context of the last
ChannelHandler in this pipeline. |
ChannelHandlerContext |
DefaultChannelPipeline.lastContext() |
ChannelHandlerContext |
ChannelHandlerContext.read() |
Modifier and Type | Method and Description |
---|---|
void |
ChannelOutboundHandler.bind(ChannelHandlerContext ctx,
SocketAddress localAddress,
ChannelPromise promise)
Called once a bind operation is made.
|
void |
CombinedChannelDuplexHandler.bind(ChannelHandlerContext ctx,
SocketAddress localAddress,
ChannelPromise promise) |
void |
ChannelDuplexHandler.bind(ChannelHandlerContext ctx,
SocketAddress localAddress,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.bind(SocketAddress, ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
ChannelOutboundHandlerAdapter.bind(ChannelHandlerContext ctx,
SocketAddress localAddress,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.bind(SocketAddress, ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
ChannelInboundHandler.channelActive(ChannelHandlerContext ctx)
The
Channel of the ChannelHandlerContext is now active |
void |
CombinedChannelDuplexHandler.channelActive(ChannelHandlerContext ctx) |
void |
ChannelInboundHandlerAdapter.channelActive(ChannelHandlerContext ctx)
|
void |
ChannelInboundHandler.channelInactive(ChannelHandlerContext ctx)
The
Channel of the ChannelHandlerContext was registered is now inactive and reached its
end of lifetime. |
void |
CombinedChannelDuplexHandler.channelInactive(ChannelHandlerContext ctx) |
void |
ChannelInboundHandlerAdapter.channelInactive(ChannelHandlerContext ctx)
|
void |
ChannelInboundHandler.channelRead(ChannelHandlerContext ctx,
Object msg)
Invoked when the current
Channel has read a message from the peer. |
void |
SimpleChannelInboundHandler.channelRead(ChannelHandlerContext ctx,
Object msg) |
void |
CombinedChannelDuplexHandler.channelRead(ChannelHandlerContext ctx,
Object msg) |
void |
ChannelInboundHandlerAdapter.channelRead(ChannelHandlerContext ctx,
Object msg)
|
protected abstract void |
SimpleChannelInboundHandler.channelRead0(ChannelHandlerContext ctx,
I msg)
Is called for each message of type
I . |
void |
ChannelInboundHandler.channelReadComplete(ChannelHandlerContext ctx)
Invoked when the last message read by the current read operation has been consumed by
ChannelInboundHandler.channelRead(ChannelHandlerContext, Object) . |
void |
CombinedChannelDuplexHandler.channelReadComplete(ChannelHandlerContext ctx) |
void |
ChannelInboundHandlerAdapter.channelReadComplete(ChannelHandlerContext ctx)
Calls
fireChannelReadComplete() to forward
to the next ChannelInboundHandler in the ChannelPipeline . |
void |
ChannelInitializer.channelRegistered(ChannelHandlerContext ctx) |
void |
ChannelInboundHandler.channelRegistered(ChannelHandlerContext ctx)
|
void |
CombinedChannelDuplexHandler.channelRegistered(ChannelHandlerContext ctx) |
void |
ChannelInboundHandlerAdapter.channelRegistered(ChannelHandlerContext ctx)
|
void |
ChannelInboundHandler.channelUnregistered(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.channelWritabilityChanged(ChannelHandlerContext ctx)
Gets called once the writable state of a
Channel changed. |
void |
CombinedChannelDuplexHandler.channelWritabilityChanged(ChannelHandlerContext ctx) |
void |
ChannelInboundHandlerAdapter.channelWritabilityChanged(ChannelHandlerContext ctx)
Calls
fireChannelWritabilityChanged() to forward
to the next ChannelInboundHandler in the ChannelPipeline . |
void |
ChannelOutboundHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise)
Called once a close operation is made.
|
void |
CombinedChannelDuplexHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
ChannelDuplexHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.close(ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
ChannelOutboundHandlerAdapter.close(ChannelHandlerContext ctx,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.close(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 |
CombinedChannelDuplexHandler.connect(ChannelHandlerContext ctx,
SocketAddress remoteAddress,
SocketAddress localAddress,
ChannelPromise promise) |
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 |
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.deregister(ChannelHandlerContext ctx,
ChannelPromise promise)
Called once a deregister operation is made from the current registered
EventLoop . |
void |
CombinedChannelDuplexHandler.deregister(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
ChannelDuplexHandler.deregister(ChannelHandlerContext ctx,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.deregister(ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
ChannelOutboundHandlerAdapter.deregister(ChannelHandlerContext ctx,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.deregister(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 |
CombinedChannelDuplexHandler.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
ChannelDuplexHandler.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.disconnect(ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
ChannelOutboundHandlerAdapter.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.disconnect(ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
protected abstract void |
SimpleUserEventChannelHandler.eventReceived(ChannelHandlerContext ctx,
I evt)
Is called for each user event triggered of type
I . |
void |
ChannelInitializer.exceptionCaught(ChannelHandlerContext ctx,
Throwable cause)
|
void |
ChannelInboundHandler.exceptionCaught(ChannelHandlerContext ctx,
Throwable cause)
Gets called if a
Throwable was thrown. |
void |
CombinedChannelDuplexHandler.exceptionCaught(ChannelHandlerContext ctx,
Throwable cause) |
void |
ChannelInboundHandlerAdapter.exceptionCaught(ChannelHandlerContext ctx,
Throwable cause)
|
void |
ChannelHandler.exceptionCaught(ChannelHandlerContext ctx,
Throwable cause)
Deprecated.
if you want to handle this event you should implement
ChannelInboundHandler and
implement the method there. |
void |
ChannelHandlerAdapter.exceptionCaught(ChannelHandlerContext ctx,
Throwable cause)
Deprecated.
is part of
ChannelInboundHandler |
void |
ChannelOutboundHandler.flush(ChannelHandlerContext ctx)
Called once a flush operation is made.
|
void |
CombinedChannelDuplexHandler.flush(ChannelHandlerContext ctx) |
void |
ChannelDuplexHandler.flush(ChannelHandlerContext ctx)
|
void |
ChannelOutboundHandlerAdapter.flush(ChannelHandlerContext ctx)
|
void |
ChannelInitializer.handlerAdded(ChannelHandlerContext ctx)
Do nothing by default, sub-classes may override this method.
|
void |
CombinedChannelDuplexHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
ChannelHandler.handlerAdded(ChannelHandlerContext ctx)
Gets called after the
ChannelHandler was added to the actual context and it's ready to handle events. |
void |
ChannelHandlerAdapter.handlerAdded(ChannelHandlerContext ctx)
Do nothing by default, sub-classes may override this method.
|
void |
ChannelInitializer.handlerRemoved(ChannelHandlerContext ctx) |
void |
CombinedChannelDuplexHandler.handlerRemoved(ChannelHandlerContext ctx) |
void |
ChannelHandler.handlerRemoved(ChannelHandlerContext ctx)
Gets called after the
ChannelHandler was removed from the actual context and it doesn't handle events
anymore. |
void |
ChannelHandlerAdapter.handlerRemoved(ChannelHandlerContext ctx)
Do nothing by default, sub-classes may override this method.
|
protected void |
DefaultChannelPipeline.onUnhandledInboundMessage(ChannelHandlerContext ctx,
Object msg)
Called once a message hit the end of the
ChannelPipeline without been handled by the user
in ChannelInboundHandler.channelRead(ChannelHandlerContext, Object) . |
void |
ChannelOutboundHandler.read(ChannelHandlerContext ctx)
Intercepts
read() . |
void |
CombinedChannelDuplexHandler.read(ChannelHandlerContext ctx) |
void |
ChannelDuplexHandler.read(ChannelHandlerContext ctx)
|
void |
ChannelOutboundHandlerAdapter.read(ChannelHandlerContext ctx)
|
void |
SimpleUserEventChannelHandler.userEventTriggered(ChannelHandlerContext ctx,
Object evt) |
void |
ChannelInboundHandler.userEventTriggered(ChannelHandlerContext ctx,
Object evt)
Gets called if an user event was triggered.
|
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 |
ChannelOutboundHandler.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise)
Called once a write operation is made.
|
void |
CombinedChannelDuplexHandler.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise) |
void |
ChannelDuplexHandler.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.write(Object, ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
ChannelOutboundHandlerAdapter.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.write(Object, ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
AbstractCoalescingBufferQueue.writeAndRemoveAll(ChannelHandlerContext ctx)
Writes all remaining elements in this queue.
|
Constructor and Description |
---|
PendingWriteQueue(ChannelHandlerContext ctx) |
Modifier and Type | Method and Description |
---|---|
void |
ResolveAddressHandler.connect(ChannelHandlerContext ctx,
SocketAddress remoteAddress,
SocketAddress localAddress,
ChannelPromise promise) |
void |
DynamicAddressConnectHandler.connect(ChannelHandlerContext ctx,
SocketAddress remoteAddress,
SocketAddress localAddress,
ChannelPromise promise) |
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 |
ByteToMessageDecoder.callDecode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out)
Called once data should be decoded from the given
ByteBuf . |
protected void |
ReplayingDecoder.callDecode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
void |
DatagramPacketDecoder.channelActive(ChannelHandlerContext ctx) |
void |
ByteToMessageCodec.channelInactive(ChannelHandlerContext ctx) |
void |
ByteToMessageDecoder.channelInactive(ChannelHandlerContext ctx) |
void |
DatagramPacketDecoder.channelInactive(ChannelHandlerContext ctx) |
void |
MessageAggregator.channelInactive(ChannelHandlerContext ctx) |
void |
MessageToMessageCodec.channelRead(ChannelHandlerContext ctx,
Object msg) |
void |
ByteToMessageCodec.channelRead(ChannelHandlerContext ctx,
Object msg) |
void |
ByteToMessageDecoder.channelRead(ChannelHandlerContext ctx,
Object msg) |
void |
MessageToMessageDecoder.channelRead(ChannelHandlerContext ctx,
Object msg) |
void |
MessageToMessageCodec.channelReadComplete(ChannelHandlerContext ctx) |
void |
ByteToMessageCodec.channelReadComplete(ChannelHandlerContext ctx) |
void |
ByteToMessageDecoder.channelReadComplete(ChannelHandlerContext ctx) |
void |
DatagramPacketDecoder.channelReadComplete(ChannelHandlerContext ctx) |
void |
MessageToMessageDecoder.channelReadComplete(ChannelHandlerContext ctx) |
void |
MessageAggregator.channelReadComplete(ChannelHandlerContext ctx) |
void |
DatagramPacketDecoder.channelRegistered(ChannelHandlerContext ctx) |
void |
DatagramPacketDecoder.channelUnregistered(ChannelHandlerContext ctx) |
void |
DatagramPacketDecoder.channelWritabilityChanged(ChannelHandlerContext ctx) |
void |
DatagramPacketEncoder.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
DatagramPacketEncoder.connect(ChannelHandlerContext ctx,
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 |
DelimiterBasedFrameDecoder.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 void |
LineBasedFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected abstract void |
ByteToMessageCodec.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 void |
DelimiterBasedFrameDecoder.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 |
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 |
ByteToMessageCodec.decodeLast(ChannelHandlerContext ctx,
ByteBuf in,
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. |
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 |
ByteToMessageCodec.encode(ChannelHandlerContext ctx,
I msg,
ByteBuf out) |
protected abstract void |
MessageToByteEncoder.encode(ChannelHandlerContext ctx,
I msg,
ByteBuf out)
Encode a message into a
ByteBuf . |
protected abstract void |
MessageToMessageEncoder.encode(ChannelHandlerContext ctx,
I msg,
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 |
ByteToMessageCodec.handlerAdded(ChannelHandlerContext ctx) |
void |
DatagramPacketEncoder.handlerAdded(ChannelHandlerContext ctx) |
void |
DatagramPacketDecoder.handlerAdded(ChannelHandlerContext ctx) |
void |
MessageAggregator.handlerAdded(ChannelHandlerContext ctx) |
void |
ByteToMessageCodec.handlerRemoved(ChannelHandlerContext ctx) |
void |
DatagramPacketEncoder.handlerRemoved(ChannelHandlerContext ctx) |
void |
ByteToMessageDecoder.handlerRemoved(ChannelHandlerContext ctx) |
void |
DatagramPacketDecoder.handlerRemoved(ChannelHandlerContext ctx) |
void |
MessageAggregator.handlerRemoved(ChannelHandlerContext ctx) |
protected void |
ByteToMessageDecoder.handlerRemoved0(ChannelHandlerContext ctx)
Gets called after the
ByteToMessageDecoder was removed from the actual context and it doesn't handle
events anymore. |
void |
DatagramPacketEncoder.read(ChannelHandlerContext ctx) |
void |
ByteToMessageDecoder.userEventTriggered(ChannelHandlerContext ctx,
Object evt) |
void |
DatagramPacketDecoder.userEventTriggered(ChannelHandlerContext ctx,
Object evt) |
void |
MessageToMessageCodec.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise) |
void |
ByteToMessageCodec.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise) |
void |
MessageToMessageEncoder.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise) |
void |
MessageToByteEncoder.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 |
JdkZlibEncoder.allocateBuffer(ChannelHandlerContext ctx,
ByteBuf msg,
boolean preferDirect) |
protected ByteBuf |
Lz4FrameEncoder.allocateBuffer(ChannelHandlerContext ctx,
ByteBuf msg,
boolean preferDirect) |
protected ByteBuf |
BrotliEncoder.allocateBuffer(ChannelHandlerContext ctx,
ByteBuf msg,
boolean preferDirect) |
protected ByteBuf |
LzmaFrameEncoder.allocateBuffer(ChannelHandlerContext ctx,
ByteBuf in,
boolean preferDirect) |
protected ByteBuf |
ZstdEncoder.allocateBuffer(ChannelHandlerContext ctx,
ByteBuf msg,
boolean preferDirect) |
void |
BrotliDecoder.channelInactive(ChannelHandlerContext ctx) |
void |
JdkZlibEncoder.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
Lz4FrameEncoder.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
JZlibEncoder.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
BrotliEncoder.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
Bzip2Encoder.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
protected void |
FastLzFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
Lz4FrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
BrotliDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
JZlibDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
Bzip2Decoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
ZstdDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
SnappyFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
JdkZlibDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
LzfDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
JdkZlibEncoder.encode(ChannelHandlerContext ctx,
ByteBuf uncompressed,
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 |
FastLzFrameEncoder.encode(ChannelHandlerContext ctx,
ByteBuf in,
ByteBuf out) |
protected void |
JZlibEncoder.encode(ChannelHandlerContext ctx,
ByteBuf in,
ByteBuf out) |
protected void |
BrotliEncoder.encode(ChannelHandlerContext ctx,
ByteBuf msg,
ByteBuf out) |
protected void |
LzmaFrameEncoder.encode(ChannelHandlerContext ctx,
ByteBuf in,
ByteBuf out) |
protected void |
SnappyFrameEncoder.encode(ChannelHandlerContext ctx,
ByteBuf in,
ByteBuf out) |
protected void |
ZstdEncoder.encode(ChannelHandlerContext ctx,
ByteBuf in,
ByteBuf out) |
protected void |
Bzip2Encoder.encode(ChannelHandlerContext ctx,
ByteBuf in,
ByteBuf out) |
void |
BrotliEncoder.finish(ChannelHandlerContext ctx)
Finish the encoding, close streams and write final
ByteBuf to the channel. |
void |
Lz4FrameEncoder.flush(ChannelHandlerContext ctx) |
void |
ZstdEncoder.flush(ChannelHandlerContext ctx) |
void |
BrotliDecoder.handlerAdded(ChannelHandlerContext ctx) |
void |
JdkZlibEncoder.handlerAdded(ChannelHandlerContext ctx) |
void |
ZstdDecoder.handlerAdded(ChannelHandlerContext ctx) |
void |
Lz4FrameEncoder.handlerAdded(ChannelHandlerContext ctx) |
void |
JZlibEncoder.handlerAdded(ChannelHandlerContext ctx) |
void |
BrotliEncoder.handlerAdded(ChannelHandlerContext ctx) |
void |
ZstdEncoder.handlerAdded(ChannelHandlerContext ctx) |
void |
Bzip2Encoder.handlerAdded(ChannelHandlerContext ctx) |
void |
LzfEncoder.handlerRemoved(ChannelHandlerContext ctx) |
void |
Lz4FrameEncoder.handlerRemoved(ChannelHandlerContext ctx) |
void |
BrotliEncoder.handlerRemoved(ChannelHandlerContext ctx) |
void |
ZstdEncoder.handlerRemoved(ChannelHandlerContext ctx) |
protected void |
BrotliDecoder.handlerRemoved0(ChannelHandlerContext ctx) |
protected void |
ZstdDecoder.handlerRemoved0(ChannelHandlerContext ctx) |
protected void |
JdkZlibDecoder.handlerRemoved0(ChannelHandlerContext ctx) |
protected ByteBuf |
ZlibDecoder.prepareDecompressBuffer(ChannelHandlerContext ctx,
ByteBuf buffer,
int preferredSize)
Allocate or expand the decompression buffer, without exceeding the maximum allocation.
|
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 ByteBuf |
TcpDnsQueryEncoder.allocateBuffer(ChannelHandlerContext ctx,
DnsQuery msg,
boolean preferDirect) |
protected Object |
TcpDnsResponseDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in) |
protected Object |
TcpDnsQueryDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in) |
protected void |
DatagramDnsQueryDecoder.decode(ChannelHandlerContext ctx,
DatagramPacket packet,
List<Object> out) |
protected void |
DatagramDnsResponseDecoder.decode(ChannelHandlerContext ctx,
DatagramPacket packet,
List<Object> out) |
protected DnsResponse |
DatagramDnsResponseDecoder.decodeResponse(ChannelHandlerContext ctx,
DatagramPacket packet) |
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) |
protected void |
TcpDnsQueryEncoder.encode(ChannelHandlerContext ctx,
DnsQuery msg,
ByteBuf out) |
protected void |
TcpDnsResponseEncoder.encode(ChannelHandlerContext ctx,
DnsResponse response,
List<Object> out) |
protected ByteBuf |
TcpDnsResponseDecoder.extractFrame(ChannelHandlerContext ctx,
ByteBuf buffer,
int index,
int length) |
Modifier and Type | Method and Description |
---|---|
void |
HAProxyMessageDecoder.channelRead(ChannelHandlerContext ctx,
Object msg) |
protected void |
HAProxyMessageDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
HAProxyMessageEncoder.encode(ChannelHandlerContext ctx,
HAProxyMessage msg,
ByteBuf 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 |
HttpContentDecoder.channelInactive(ChannelHandlerContext ctx) |
void |
HttpContentEncoder.channelInactive(ChannelHandlerContext ctx) |
void |
HttpServerKeepAliveHandler.channelRead(ChannelHandlerContext ctx,
Object msg) |
void |
HttpServerExpectContinueHandler.channelRead(ChannelHandlerContext ctx,
Object msg) |
void |
HttpContentDecoder.channelReadComplete(ChannelHandlerContext ctx) |
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 |
HttpClientUpgradeHandler.decode(ChannelHandlerContext ctx,
HttpObject msg,
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 |
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 |
HttpContentDecoder.handlerRemoved(ChannelHandlerContext ctx) |
void |
HttpContentEncoder.handlerRemoved(ChannelHandlerContext ctx) |
protected void |
HttpObjectDecoder.handlerRemoved0(ChannelHandlerContext ctx) |
void |
HttpClientCodec.prepareUpgradeFrom(ChannelHandlerContext ctx)
Prepares to upgrade to another protocol from HTTP.
|
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). |
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 |
HttpClientCodec.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 |
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 |
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 |
HttpObjectEncoder.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise) |
void |
HttpClientUpgradeHandler.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise) |
void |
HttpServerKeepAliveHandler.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) |
ChannelFuture |
WebSocketServerHandshaker.close(ChannelHandlerContext ctx,
CloseWebSocketFrame frame)
Performs the closing handshake.
|
ChannelFuture |
WebSocketClientHandshaker.close(ChannelHandlerContext ctx,
CloseWebSocketFrame frame)
Performs the closing handshake
|
ChannelFuture |
WebSocketServerHandshaker.close(ChannelHandlerContext ctx,
CloseWebSocketFrame frame,
ChannelPromise promise)
Performs the closing handshake.
|
ChannelFuture |
WebSocketServerHandshaker00.close(ChannelHandlerContext ctx,
CloseWebSocketFrame frame,
ChannelPromise promise)
Echo back the closing frame
|
ChannelFuture |
WebSocketClientHandshaker.close(ChannelHandlerContext ctx,
CloseWebSocketFrame frame,
ChannelPromise promise)
Performs the closing handshake
|
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 |
WebSocket00FrameEncoder.encode(ChannelHandlerContext ctx,
WebSocketFrame msg,
List<Object> out) |
protected void |
WebSocket08FrameEncoder.encode(ChannelHandlerContext ctx,
WebSocketFrame msg,
List<Object> out) |
void |
Utf8FrameValidator.exceptionCaught(ChannelHandlerContext ctx,
Throwable cause) |
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 |
WebSocketClientExtensionHandler.channelRead(ChannelHandlerContext ctx,
Object msg) |
void |
WebSocketServerExtensionHandler.channelRead(ChannelHandlerContext ctx,
Object msg) |
protected void |
WebSocketServerExtensionHandler.onHttpRequestChannelRead(ChannelHandlerContext ctx,
HttpRequest request)
This is a method exposed to perform fail-fast checks of user-defined http types.
|
protected void |
WebSocketServerExtensionHandler.onHttpResponseWrite(ChannelHandlerContext ctx,
HttpResponse response,
ChannelPromise promise)
This is a method exposed to perform fail-fast checks of user-defined http types.
|
void |
WebSocketClientExtensionHandler.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise) |
void |
WebSocketServerExtensionHandler.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
ChannelHandlerContext |
DefaultHttp2RemoteFlowController.channelHandlerContext() |
ChannelHandlerContext |
Http2RemoteFlowController.channelHandlerContext()
Get the
ChannelHandlerContext for which to apply flow control on. |
Modifier and Type | Method and Description |
---|---|
void |
Http2ConnectionHandler.bind(ChannelHandlerContext ctx,
SocketAddress localAddress,
ChannelPromise promise) |
void |
Http2ConnectionHandler.channelActive(ChannelHandlerContext ctx) |
void |
DefaultHttp2LocalFlowController.channelHandlerContext(ChannelHandlerContext ctx) |
void |
DefaultHttp2RemoteFlowController.channelHandlerContext(ChannelHandlerContext ctx)
Set the
ChannelHandlerContext for which to apply flow control on. |
void |
Http2FlowController.channelHandlerContext(ChannelHandlerContext ctx)
Set the
ChannelHandlerContext for which to apply flow control on. |
void |
Http2ConnectionHandler.channelInactive(ChannelHandlerContext ctx) |
void |
Http2MultiplexCodec.channelRead(ChannelHandlerContext ctx,
Object msg)
Deprecated.
|
void |
Http2MultiplexHandler.channelRead(ChannelHandlerContext ctx,
Object msg) |
void |
InboundHttpToHttp2Adapter.channelRead(ChannelHandlerContext ctx,
Object msg) |
void |
Http2MultiplexCodec.channelReadComplete(ChannelHandlerContext ctx)
Deprecated.
Notifies any child streams of the read completion.
|
void |
Http2ConnectionHandler.channelReadComplete(ChannelHandlerContext ctx) |
void |
Http2MultiplexHandler.channelReadComplete(ChannelHandlerContext ctx)
Notifies any child streams of the read completion.
|
void |
Http2MultiplexCodec.channelWritabilityChanged(ChannelHandlerContext ctx)
Deprecated.
|
void |
Http2ConnectionHandler.channelWritabilityChanged(ChannelHandlerContext ctx) |
void |
Http2MultiplexHandler.channelWritabilityChanged(ChannelHandlerContext ctx) |
void |
Http2ConnectionHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
Http2ConnectionHandler.connect(ChannelHandlerContext ctx,
SocketAddress remoteAddress,
SocketAddress localAddress,
ChannelPromise promise) |
protected void |
CleartextHttp2ServerUpgradeHandler.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out)
Peek inbound message to determine current connection wants to start HTTP/2
by HTTP upgrade or prior knowledge
|
protected void |
Http2ConnectionHandler.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
Http2StreamFrameToHttpObjectCodec.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 |
DecoratingHttp2ConnectionDecoder.decodeFrame(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
void |
DefaultHttp2ConnectionDecoder.decodeFrame(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
void |
Http2ConnectionHandler.deregister(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
Http2ConnectionHandler.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise) |
protected void |
Http2StreamFrameToHttpObjectCodec.encode(ChannelHandlerContext ctx,
HttpObject obj,
List<Object> out)
Encode from an
HttpObject to an Http2StreamFrame . |
void |
Http2RemoteFlowController.FlowControlled.error(ChannelHandlerContext ctx,
Throwable cause)
Called to indicate that an error occurred before this object could be completely written.
|
void |
Http2ConnectionHandler.exceptionCaught(ChannelHandlerContext ctx,
Throwable cause)
Handles
Http2Exception objects that were thrown from other handlers. |
void |
Http2MultiplexHandler.exceptionCaught(ChannelHandlerContext ctx,
Throwable cause) |
protected void |
InboundHttp2ToHttpAdapter.fireChannelRead(ChannelHandlerContext ctx,
FullHttpMessage msg,
boolean release,
Http2Stream stream)
Set final headers and fire a channel read event
|
void |
Http2ConnectionHandler.flush(ChannelHandlerContext ctx) |
ChannelFuture |
Http2ConnectionHandler.goAway(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData,
ChannelPromise promise) |
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 . |
void |
CleartextHttp2ServerUpgradeHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
Http2ConnectionHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
Http2StreamFrameToHttpObjectCodec.handlerAdded(ChannelHandlerContext ctx) |
void |
Http2ChannelDuplexHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
Http2FrameCodec.handlerAdded(ChannelHandlerContext ctx) |
void |
Http2MultiplexCodec.handlerAdded0(ChannelHandlerContext ctx)
Deprecated.
|
protected void |
Http2ChannelDuplexHandler.handlerAdded0(ChannelHandlerContext ctx) |
protected void |
Http2MultiplexHandler.handlerAdded0(ChannelHandlerContext ctx) |
void |
Http2ChannelDuplexHandler.handlerRemoved(ChannelHandlerContext ctx) |
void |
Http2MultiplexCodec.handlerRemoved0(ChannelHandlerContext ctx)
Deprecated.
|
protected void |
Http2ConnectionHandler.handlerRemoved0(ChannelHandlerContext ctx) |
protected void |
Http2ChannelDuplexHandler.handlerRemoved0(ChannelHandlerContext ctx) |
protected void |
Http2MultiplexHandler.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 . |
protected boolean |
Http2StreamFrameToHttpObjectCodec.isSsl(ChannelHandlerContext ctx) |
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,
long data) |
void |
Http2FrameLogger.logPingAck(Http2FrameLogger.Direction direction,
ChannelHandlerContext ctx,
long 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,
boolean outbound,
Throwable cause,
Http2Exception http2Ex)
Handler for a connection error.
|
protected void |
Http2FrameCodec.onConnectionError(ChannelHandlerContext ctx,
boolean outbound,
Throwable cause,
Http2Exception http2Ex) |
int |
Http2FrameAdapter.onDataRead(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endOfStream) |
int |
DelegatingDecompressorFrameListener.onDataRead(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endOfStream) |
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 |
Http2EventAdapter.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. |
void |
Http2ConnectionHandler.onError(ChannelHandlerContext ctx,
boolean outbound,
Throwable cause)
Central handler for all exceptions caught during HTTP/2 processing.
|
void |
Http2LifecycleManager.onError(ChannelHandlerContext ctx,
boolean outbound,
Throwable cause)
Processes the given error.
|
void |
Http2FrameAdapter.onGoAwayRead(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData) |
void |
Http2FrameListenerDecorator.onGoAwayRead(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData) |
void |
Http2EventAdapter.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.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 padding,
boolean endOfStream) |
void |
Http2FrameListenerDecorator.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 |
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 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 |
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 |
Http2EventAdapter.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.onPingAckRead(ChannelHandlerContext ctx,
long data) |
void |
Http2FrameListenerDecorator.onPingAckRead(ChannelHandlerContext ctx,
long data) |
void |
Http2EventAdapter.onPingAckRead(ChannelHandlerContext ctx,
long data) |
void |
Http2FrameListener.onPingAckRead(ChannelHandlerContext ctx,
long data)
Handles an inbound
PING acknowledgment. |
void |
Http2FrameAdapter.onPingRead(ChannelHandlerContext ctx,
long data) |
void |
Http2FrameListenerDecorator.onPingRead(ChannelHandlerContext ctx,
long data) |
void |
Http2EventAdapter.onPingRead(ChannelHandlerContext ctx,
long data) |
void |
Http2FrameListener.onPingRead(ChannelHandlerContext ctx,
long data)
Handles an inbound
PING frame. |
void |
Http2FrameAdapter.onPriorityRead(ChannelHandlerContext ctx,
int streamId,
int streamDependency,
short weight,
boolean exclusive) |
void |
Http2FrameListenerDecorator.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 |
Http2FrameListener.onPriorityRead(ChannelHandlerContext ctx,
int streamId,
int streamDependency,
short weight,
boolean exclusive)
Handles an inbound
PRIORITY frame. |
void |
Http2FrameAdapter.onPushPromiseRead(ChannelHandlerContext ctx,
int streamId,
int promisedStreamId,
Http2Headers headers,
int padding) |
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 |
Http2EventAdapter.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.onRstStreamRead(ChannelHandlerContext ctx,
int streamId,
long errorCode) |
void |
InboundHttp2ToHttpAdapter.onRstStreamRead(ChannelHandlerContext ctx,
int streamId,
long errorCode) |
void |
Http2FrameListenerDecorator.onRstStreamRead(ChannelHandlerContext ctx,
int streamId,
long errorCode) |
void |
Http2EventAdapter.onRstStreamRead(ChannelHandlerContext ctx,
int streamId,
long errorCode) |
void |
Http2FrameListener.onRstStreamRead(ChannelHandlerContext ctx,
int streamId,
long errorCode)
Handles an inbound
RST_STREAM frame. |
void |
Http2FrameAdapter.onSettingsAckRead(ChannelHandlerContext ctx) |
void |
Http2FrameListenerDecorator.onSettingsAckRead(ChannelHandlerContext ctx) |
void |
Http2EventAdapter.onSettingsAckRead(ChannelHandlerContext ctx) |
void |
Http2FrameListener.onSettingsAckRead(ChannelHandlerContext ctx)
Handles an inbound
SETTINGS acknowledgment frame. |
void |
Http2FrameAdapter.onSettingsRead(ChannelHandlerContext ctx,
Http2Settings settings) |
void |
InboundHttp2ToHttpAdapter.onSettingsRead(ChannelHandlerContext ctx,
Http2Settings settings) |
void |
Http2FrameListenerDecorator.onSettingsRead(ChannelHandlerContext ctx,
Http2Settings settings) |
void |
Http2EventAdapter.onSettingsRead(ChannelHandlerContext ctx,
Http2Settings settings) |
void |
Http2FrameListener.onSettingsRead(ChannelHandlerContext ctx,
Http2Settings settings)
Handles an inbound
SETTINGS frame. |
protected void |
Http2ConnectionHandler.onStreamError(ChannelHandlerContext ctx,
boolean outbound,
Throwable cause,
Http2Exception.StreamException http2Ex)
Handler for a stream error.
|
protected void |
Http2FrameCodec.onStreamError(ChannelHandlerContext ctx,
boolean outbound,
Throwable cause,
Http2Exception.StreamException streamException)
Exceptions for unknown streams, that is streams that have no
Http2FrameStream object attached
are simply logged and replied to by sending a RST_STREAM frame. |
void |
Http2FrameAdapter.onUnknownFrame(ChannelHandlerContext ctx,
byte frameType,
int streamId,
Http2Flags flags,
ByteBuf payload) |
void |
Http2FrameListenerDecorator.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 |
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.onWindowUpdateRead(ChannelHandlerContext ctx,
int streamId,
int windowSizeIncrement) |
void |
Http2FrameListenerDecorator.onWindowUpdateRead(ChannelHandlerContext ctx,
int streamId,
int windowSizeIncrement) |
void |
Http2EventAdapter.onWindowUpdateRead(ChannelHandlerContext ctx,
int streamId,
int windowSizeIncrement) |
void |
Http2FrameListener.onWindowUpdateRead(ChannelHandlerContext ctx,
int streamId,
int windowSizeIncrement)
Handles an inbound
WINDOW_UPDATE frame. |
void |
Http2StreamChannelBootstrap.open0(ChannelHandlerContext ctx,
Promise<Http2StreamChannel> promise)
Deprecated.
should not be used directly. Use
Http2StreamChannelBootstrap.open() or Http2StreamChannelBootstrap.open(Promise) |
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) |
Http2DataFrame |
Http2DataChunkedInput.readChunk(ChannelHandlerContext ctx)
Deprecated.
|
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 |
Http2ConnectionHandler.resetStream(ChannelHandlerContext ctx,
int streamId,
long errorCode,
ChannelPromise promise) |
ChannelFuture |
Http2LifecycleManager.resetStream(ChannelHandlerContext ctx,
int streamId,
long errorCode,
ChannelPromise promise)
Ensure the stream identified by
streamId is reset. |
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 |
Http2MultiplexHandler.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 |
Http2ConnectionHandler.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise) |
void |
Http2FrameCodec.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise)
Processes all
Http2Frame s. |
void |
HttpToHttp2ConnectionHandler.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise)
Handles conversion of
HttpMessage and HttpContent to HTTP/2 frames. |
ChannelFuture |
Http2DataWriter.writeData(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endStream,
ChannelPromise promise)
Writes a
DATA frame to the remote endpoint. |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writeData(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endOfStream,
ChannelPromise promise) |
ChannelFuture |
StreamBufferingEncoder.writeData(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endOfStream,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2FrameWriter.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 |
DecoratingHttp2FrameWriter.writeData(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endStream,
ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writeData(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endStream,
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 |
DefaultHttp2ConnectionEncoder.writeFrame(ChannelHandlerContext ctx,
byte frameType,
int streamId,
Http2Flags flags,
ByteBuf payload,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2FrameWriter.writeFrame(ChannelHandlerContext ctx,
byte frameType,
int streamId,
Http2Flags flags,
ByteBuf payload,
ChannelPromise promise) |
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 |
DecoratingHttp2FrameWriter.writeFrame(ChannelHandlerContext ctx,
byte frameType,
int streamId,
Http2Flags flags,
ByteBuf payload,
ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writeFrame(ChannelHandlerContext ctx,
byte frameType,
int streamId,
Http2Flags flags,
ByteBuf payload,
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 |
DefaultHttp2ConnectionEncoder.writeGoAway(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2FrameWriter.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 |
Http2OutboundFrameLogger.writeGoAway(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData,
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 |
DefaultHttp2ConnectionEncoder.writeHeaders(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int padding,
boolean endStream,
ChannelPromise promise) |
ChannelFuture |
StreamBufferingEncoder.writeHeaders(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int padding,
boolean endStream,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2FrameWriter.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 |
DecoratingHttp2FrameWriter.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 streamDependency,
short weight,
boolean exclusive,
int padding,
boolean endStream,
ChannelPromise promise)
Writes a HEADERS frame with priority specified to the remote endpoint.
|
ChannelFuture |
DefaultHttp2ConnectionEncoder.writeHeaders(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int streamDependency,
short weight,
boolean exclusive,
int padding,
boolean endOfStream,
ChannelPromise promise) |
ChannelFuture |
StreamBufferingEncoder.writeHeaders(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int streamDependency,
short weight,
boolean exclusive,
int padding,
boolean endOfStream,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2FrameWriter.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 |
DecoratingHttp2FrameWriter.writeHeaders(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int streamDependency,
short weight,
boolean exclusive,
int padding,
boolean endStream,
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.writePing(ChannelHandlerContext ctx,
boolean ack,
long data,
ChannelPromise promise)
Writes a PING frame to the remote endpoint.
|
ChannelFuture |
DefaultHttp2ConnectionEncoder.writePing(ChannelHandlerContext ctx,
boolean ack,
long data,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2FrameWriter.writePing(ChannelHandlerContext ctx,
boolean ack,
long data,
ChannelPromise promise) |
ChannelFuture |
DecoratingHttp2FrameWriter.writePing(ChannelHandlerContext ctx,
boolean ack,
long data,
ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writePing(ChannelHandlerContext ctx,
boolean ack,
long data,
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 |
DefaultHttp2ConnectionEncoder.writePriority(ChannelHandlerContext ctx,
int streamId,
int streamDependency,
short weight,
boolean exclusive,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2FrameWriter.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.writePriority(ChannelHandlerContext ctx,
int streamId,
int streamDependency,
short weight,
boolean exclusive,
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 |
DefaultHttp2ConnectionEncoder.writePushPromise(ChannelHandlerContext ctx,
int streamId,
int promisedStreamId,
Http2Headers headers,
int padding,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2FrameWriter.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 |
Http2OutboundFrameLogger.writePushPromise(ChannelHandlerContext ctx,
int streamId,
int promisedStreamId,
Http2Headers headers,
int padding,
ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writeRstStream(ChannelHandlerContext ctx,
int streamId,
long errorCode,
ChannelPromise promise)
Writes a RST_STREAM frame to the remote endpoint.
|
ChannelFuture |
DefaultHttp2ConnectionEncoder.writeRstStream(ChannelHandlerContext ctx,
int streamId,
long errorCode,
ChannelPromise promise) |
ChannelFuture |
StreamBufferingEncoder.writeRstStream(ChannelHandlerContext ctx,
int streamId,
long errorCode,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2FrameWriter.writeRstStream(ChannelHandlerContext ctx,
int streamId,
long errorCode,
ChannelPromise promise) |
ChannelFuture |
DecoratingHttp2FrameWriter.writeRstStream(ChannelHandlerContext ctx,
int streamId,
long errorCode,
ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writeRstStream(ChannelHandlerContext ctx,
int streamId,
long errorCode,
ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writeSettings(ChannelHandlerContext ctx,
Http2Settings settings,
ChannelPromise promise)
Writes a SETTINGS frame to the remote endpoint.
|
ChannelFuture |
DefaultHttp2ConnectionEncoder.writeSettings(ChannelHandlerContext ctx,
Http2Settings settings,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2FrameWriter.writeSettings(ChannelHandlerContext ctx,
Http2Settings settings,
ChannelPromise promise) |
ChannelFuture |
DecoratingHttp2FrameWriter.writeSettings(ChannelHandlerContext ctx,
Http2Settings settings,
ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writeSettings(ChannelHandlerContext ctx,
Http2Settings settings,
ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writeSettingsAck(ChannelHandlerContext ctx,
ChannelPromise promise)
Writes a SETTINGS acknowledgment to the remote endpoint.
|
ChannelFuture |
DefaultHttp2ConnectionEncoder.writeSettingsAck(ChannelHandlerContext ctx,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2FrameWriter.writeSettingsAck(ChannelHandlerContext ctx,
ChannelPromise promise) |
ChannelFuture |
DecoratingHttp2FrameWriter.writeSettingsAck(ChannelHandlerContext ctx,
ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writeSettingsAck(ChannelHandlerContext ctx,
ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writeWindowUpdate(ChannelHandlerContext ctx,
int streamId,
int windowSizeIncrement,
ChannelPromise promise)
Writes a WINDOW_UPDATE frame to the remote endpoint.
|
ChannelFuture |
DefaultHttp2ConnectionEncoder.writeWindowUpdate(ChannelHandlerContext ctx,
int streamId,
int windowSizeIncrement,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2FrameWriter.writeWindowUpdate(ChannelHandlerContext ctx,
int streamId,
int windowSizeIncrement,
ChannelPromise promise) |
ChannelFuture |
DecoratingHttp2FrameWriter.writeWindowUpdate(ChannelHandlerContext ctx,
int streamId,
int windowSizeIncrement,
ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.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 |
DefaultMarshallerProvider.getMarshaller(ChannelHandlerContext ctx) |
org.jboss.marshalling.Marshaller |
MarshallerProvider.getMarshaller(ChannelHandlerContext ctx)
Get a
Marshaller for the given ChannelHandlerContext |
org.jboss.marshalling.Unmarshaller |
DefaultUnmarshallerProvider.getUnmarshaller(ChannelHandlerContext ctx) |
org.jboss.marshalling.Unmarshaller |
ContextBoundUnmarshallerProvider.getUnmarshaller(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) |
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,
com.google.protobuf.nano.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 |
SctpInboundByteStreamHandler.decode(ChannelHandlerContext ctx,
SctpMessage msg,
List<Object> out) |
protected void |
SctpMessageCompletionHandler.decode(ChannelHandlerContext ctx,
SctpMessage msg,
List<Object> out) |
protected void |
SctpOutboundByteStreamHandler.encode(ChannelHandlerContext ctx,
ByteBuf msg,
List<Object> out) |
void |
SctpMessageCompletionHandler.handlerRemoved(ChannelHandlerContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected Object |
ObjectDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in)
Deprecated.
|
protected void |
CompatibleObjectEncoder.encode(ChannelHandlerContext ctx,
Serializable msg,
ByteBuf out)
Deprecated.
|
protected void |
ObjectEncoder.encode(ChannelHandlerContext ctx,
Serializable msg,
ByteBuf out)
Deprecated.
|
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 |
SocksAuthRequestDecoder.decode(ChannelHandlerContext ctx,
ByteBuf byteBuf,
List<Object> out) |
protected void |
SocksInitRequestDecoder.decode(ChannelHandlerContext ctx,
ByteBuf byteBuf,
List<Object> out) |
protected void |
SocksAuthResponseDecoder.decode(ChannelHandlerContext channelHandlerContext,
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 |
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 |
Socks5CommandResponseDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
Socks5InitialRequestDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
Socks5PasswordAuthResponseDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
Socks5PasswordAuthRequestDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
Socks5CommandRequestDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
Socks5InitialResponseDecoder.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 |
SpdyHttpDecoder.channelInactive(ChannelHandlerContext ctx) |
void |
SpdySessionHandler.channelInactive(ChannelHandlerContext ctx) |
void |
SpdySessionHandler.channelRead(ChannelHandlerContext ctx,
Object msg) |
void |
SpdyFrameCodec.channelReadComplete(ChannelHandlerContext ctx) |
void |
SpdyFrameCodec.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
SpdySessionHandler.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 |
SpdyFrameCodec.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise) |
void |
SpdySessionHandler.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 |
LineEncoder.encode(ChannelHandlerContext ctx,
CharSequence msg,
List<Object> out) |
protected void |
StringEncoder.encode(ChannelHandlerContext ctx,
CharSequence msg,
List<Object> out) |
Modifier and Type | Method and Description |
---|---|
protected void |
XmlFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
XmlDecoder.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.handlerRemoved(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 |
RuleBasedIpFilter.accept(ChannelHandlerContext ctx,
InetSocketAddress remoteAddress) |
protected boolean |
UniqueIpFilter.accept(ChannelHandlerContext ctx,
InetSocketAddress remoteAddress) |
protected boolean |
IpSubnetFilter.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 |
---|---|
void |
PcapWriteHandler.channelActive(ChannelHandlerContext ctx) |
void |
PcapWriteHandler.channelRead(ChannelHandlerContext ctx,
Object msg) |
void |
PcapWriteHandler.exceptionCaught(ChannelHandlerContext ctx,
Throwable cause) |
void |
PcapWriteHandler.handlerRemoved(ChannelHandlerContext ctx) |
void |
PcapWriteHandler.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
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 |
Socks5ProxyHandler.addCodec(ChannelHandlerContext ctx) |
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 |
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 |
Socks5ProxyHandler.handleResponse(ChannelHandlerContext ctx,
Object response) |
protected boolean |
HttpProxyHandler.handleResponse(ChannelHandlerContext ctx,
Object response) |
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 |
Socks5ProxyHandler.newInitialMessage(ChannelHandlerContext ctx) |
protected Object |
HttpProxyHandler.newInitialMessage(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 |
Socks5ProxyHandler.removeDecoder(ChannelHandlerContext ctx) |
protected void |
HttpProxyHandler.removeDecoder(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 |
Socks5ProxyHandler.removeEncoder(ChannelHandlerContext ctx) |
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 |
SslClientHelloHandler.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 |
AbstractSniHandler.channelActive(ChannelHandlerContext ctx) |
void |
SslHandler.channelInactive(ChannelHandlerContext ctx) |
void |
ApplicationProtocolNegotiationHandler.channelInactive(ChannelHandlerContext ctx) |
void |
ApplicationProtocolNegotiationHandler.channelRead(ChannelHandlerContext ctx,
Object msg) |
void |
SslHandler.channelReadComplete(ChannelHandlerContext ctx) |
void |
SslHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
SslClientHelloHandler.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 |
SslClientHelloHandler.connect(ChannelHandlerContext ctx,
SocketAddress remoteAddress,
SocketAddress localAddress,
ChannelPromise promise) |
protected void |
SslHandler.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
SslClientHelloHandler.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
OptionalSslHandler.decode(ChannelHandlerContext context,
ByteBuf in,
List<Object> out) |
void |
SslHandler.deregister(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
SslClientHelloHandler.deregister(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
SslHandler.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
SslClientHelloHandler.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 |
SslClientHelloHandler.flush(ChannelHandlerContext ctx) |
void |
SslHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
AbstractSniHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
ApplicationProtocolNegotiationHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
ApplicationProtocolNegotiationHandler.handlerRemoved(ChannelHandlerContext ctx) |
void |
SslHandler.handlerRemoved0(ChannelHandlerContext ctx) |
protected void |
SslClientHelloHandler.handlerRemoved0(ChannelHandlerContext ctx) |
protected void |
ApplicationProtocolNegotiationHandler.handshakeFailure(ChannelHandlerContext ctx,
Throwable cause)
Invoked on failed initial SSL/TLS handshake.
|
protected Future<T> |
AbstractSniHandler.lookup(ChannelHandlerContext ctx,
ByteBuf clientHello) |
protected abstract Future<T> |
SslClientHelloHandler.lookup(ChannelHandlerContext ctx,
ByteBuf clientHello)
Kicks off a lookup for the given
ClientHello and returns a Future which in turn will
notify the SslClientHelloHandler.onLookupComplete(ChannelHandlerContext, Future) on completion. |
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 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 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 |
AbstractSniHandler.onLookupComplete(ChannelHandlerContext ctx,
Future<T> future) |
protected abstract void |
SslClientHelloHandler.onLookupComplete(ChannelHandlerContext ctx,
Future<T> future)
Called upon completion of the
SslClientHelloHandler.lookup(ChannelHandlerContext, ByteBuf) Future . |
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 |
SslClientHelloHandler.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 |
SslMasterKeyHandler.userEventTriggered(ChannelHandlerContext ctx,
Object evt) |
void |
ApplicationProtocolNegotiationHandler.userEventTriggered(ChannelHandlerContext ctx,
Object evt) |
void |
SslHandler.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise) |
void |
SslClientHelloHandler.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
void |
OcspServerCertificateValidator.exceptionCaught(ChannelHandlerContext ctx,
Throwable cause) |
void |
OcspClientHandler.userEventTriggered(ChannelHandlerContext ctx,
Object evt) |
void |
OcspServerCertificateValidator.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 |
ChunkedNioStream.readChunk(ChannelHandlerContext ctx)
Deprecated.
|
B |
ChunkedInput.readChunk(ChannelHandlerContext ctx)
Deprecated.
Use
ChunkedInput.readChunk(ByteBufAllocator) .
Fetches a chunked data from the stream. Once this method returns the last chunk
and thus the stream has reached at its end, any subsequent |
ByteBuf |
ChunkedNioFile.readChunk(ChannelHandlerContext ctx)
Deprecated.
|
ByteBuf |
ChunkedFile.readChunk(ChannelHandlerContext ctx)
Deprecated.
|
ByteBuf |
ChunkedStream.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) |
void |
AbstractTrafficShapingHandler.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–2024 The Netty Project. All rights reserved.