Uses of Interface
io.netty.channel.ChannelHandlerContext
Packages that use ChannelHandlerContext
Package
Description
The helper classes with fluent API which enable an easy implementation of
typical client side and server side channel initialization.
The core channel API which is asynchronous and event-driven abstraction of
various transports such as a
NIO Channel.
A virtual
Channel
that helps wrapping a series of handlers to
unit test the handlers or use them in non-I/O context.Package to dynamically replace local / remote
SocketAddress
.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.
Encoder and decoder which transform an array of bytes into a
ByteBuf
and vice versa.DNS codec.
Decodes an HAProxy proxy protocol header
Encoder, decoder and their related message types for HTTP.
This package contains Cross Origin Resource Sharing (CORS) related classes.
HTTP multipart support.
Encoder, decoder, handshakers and their related message types for
Web Socket data frames.
Encoder, decoder, handshakers to handle
WebSocket Extensions.
Encoder, decoder, handshakers to handle most common WebSocket Compression Extensions.
Handlers for sending and receiving HTTP/2 frames.
JSON specific codecs.
Common superset of ascii and binary classes.
Implementations and Interfaces for the Memcache Binary protocol.
Encoder, decoder and different Message Types for MQTT.
Encoder, decoder for Redis.
Decoder and encoders to manage message completion and multi-streaming codec in SCTP/IP.
Encoder, decoder and their compatibility stream implementations which
transform a
Serializable
object into a byte buffer and
vice versa.SMTP codec.
Encoder, decoder and their related message types for Socks.
Encoder, decoder and their related message types for SOCKS protocol.
Encoder, decoder and their related message types for SOCKSv4 protocol.
Encoder, decoder and their related message types for SOCKSv5 protocol.
Encoder, decoder, session handler and their related message types for the SPDY protocol.
STOMP codec
Xml specific codecs.
Package to control the flow of messages.
Package to control flush behavior.
Package to filter IP addresses (allow/deny).
Logs the I/O events for debugging purpose.
Capture data and write into Pcap format which helps in troubleshooting.
Adds support for client connections via proxy protocols such as
SOCKS and
HTTP CONNECT tunneling
Certificate validation using OCSP
Writes very large data stream asynchronously neither spending a lot of
memory nor getting
OutOfMemoryError
.Adds support for read and write timeout and idle connection notification
using a
Timer
.Implementation of a Traffic Shaping Handler and Dynamic Statistics.
An alternative to Java's built-in domain name lookup mechanism that resolves a domain name asynchronously,
which supports the queries of an arbitrary DNS record type as well.
-
Uses of ChannelHandlerContext in io.netty.bootstrap
Methods in io.netty.bootstrap with parameters of type ChannelHandlerContextModifier and TypeMethodDescriptionvoid
ServerBootstrap.ServerBootstrapAcceptor.channelRead
(ChannelHandlerContext ctx, Object msg) void
ServerBootstrap.ServerBootstrapAcceptor.exceptionCaught
(ChannelHandlerContext ctx, Throwable cause) -
Uses of ChannelHandlerContext in io.netty.channel
Classes in io.netty.channel that implement ChannelHandlerContextModifier and TypeClassDescription(package private) class
private static class
(package private) final class
(package private) final class
(package private) final class
Fields in io.netty.channel declared as ChannelHandlerContextModifier and TypeFieldDescriptionprivate final ChannelHandlerContext
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.ctx
Fields in io.netty.channel with type parameters of type ChannelHandlerContextModifier and TypeFieldDescriptionprivate final Set
<ChannelHandlerContext> ChannelInitializer.initMap
Methods in io.netty.channel that return ChannelHandlerContextModifier and TypeMethodDescriptionChannelPipeline.context
(ChannelHandler handler) Returns the context object of the specifiedChannelHandler
in this pipeline.ChannelPipeline.context
(Class<? extends ChannelHandler> handlerType) Returns the context object of theChannelHandler
of the specified type in this pipeline.Returns the context object of theChannelHandler
with the specified name in this pipeline.final ChannelHandlerContext
DefaultChannelPipeline.context
(ChannelHandler handler) final ChannelHandlerContext
DefaultChannelPipeline.context
(Class<? extends ChannelHandler> handlerType) final ChannelHandlerContext
AbstractChannelHandlerContext.fireChannelActive()
ChannelHandlerContext.fireChannelActive()
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.fireChannelActive()
AbstractChannelHandlerContext.fireChannelInactive()
ChannelHandlerContext.fireChannelInactive()
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.fireChannelInactive()
AbstractChannelHandlerContext.fireChannelRead
(Object msg) ChannelHandlerContext.fireChannelRead
(Object msg) CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.fireChannelRead
(Object msg) AbstractChannelHandlerContext.fireChannelReadComplete()
ChannelHandlerContext.fireChannelReadComplete()
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.fireChannelReadComplete()
AbstractChannelHandlerContext.fireChannelRegistered()
ChannelHandlerContext.fireChannelRegistered()
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.fireChannelRegistered()
AbstractChannelHandlerContext.fireChannelUnregistered()
ChannelHandlerContext.fireChannelUnregistered()
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.fireChannelUnregistered()
AbstractChannelHandlerContext.fireChannelWritabilityChanged()
ChannelHandlerContext.fireChannelWritabilityChanged()
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.fireChannelWritabilityChanged()
AbstractChannelHandlerContext.fireExceptionCaught
(Throwable cause) ChannelHandlerContext.fireExceptionCaught
(Throwable cause) CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.fireExceptionCaught
(Throwable cause) AbstractChannelHandlerContext.fireUserEventTriggered
(Object event) ChannelHandlerContext.fireUserEventTriggered
(Object evt) CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.fireUserEventTriggered
(Object event) ChannelPipeline.firstContext()
Returns the context of the firstChannelHandler
in this pipeline.final ChannelHandlerContext
DefaultChannelPipeline.firstContext()
AbstractChannelHandlerContext.flush()
ChannelHandlerContext.flush()
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.flush()
ChannelPipeline.lastContext()
Returns the context of the lastChannelHandler
in this pipeline.final ChannelHandlerContext
DefaultChannelPipeline.lastContext()
AbstractChannelHandlerContext.read()
ChannelHandlerContext.read()
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.read()
Methods in io.netty.channel with parameters of type ChannelHandlerContextModifier and TypeMethodDescriptionvoid
ChannelDuplexHandler.bind
(ChannelHandlerContext ctx, SocketAddress localAddress, ChannelPromise promise) CallsChannelOutboundInvoker.bind(SocketAddress, ChannelPromise)
to forward to the nextChannelOutboundHandler
in theChannelPipeline
.void
ChannelOutboundHandler.bind
(ChannelHandlerContext ctx, SocketAddress localAddress, ChannelPromise promise) Called once a bind operation is made.void
ChannelOutboundHandlerAdapter.bind
(ChannelHandlerContext ctx, SocketAddress localAddress, ChannelPromise promise) CallsChannelOutboundInvoker.bind(SocketAddress, ChannelPromise)
to forward to the nextChannelOutboundHandler
in theChannelPipeline
.void
CombinedChannelDuplexHandler.bind
(ChannelHandlerContext ctx, SocketAddress localAddress, ChannelPromise promise) void
DefaultChannelPipeline.HeadContext.bind
(ChannelHandlerContext ctx, SocketAddress localAddress, ChannelPromise promise) void
ChannelInboundHandler.channelActive
(ChannelHandlerContext ctx) TheChannel
of theChannelHandlerContext
is now activevoid
ChannelInboundHandlerAdapter.channelActive
(ChannelHandlerContext ctx) void
CombinedChannelDuplexHandler.channelActive
(ChannelHandlerContext ctx) void
DefaultChannelPipeline.HeadContext.channelActive
(ChannelHandlerContext ctx) void
DefaultChannelPipeline.TailContext.channelActive
(ChannelHandlerContext ctx) void
ChannelInboundHandler.channelInactive
(ChannelHandlerContext ctx) TheChannel
of theChannelHandlerContext
was registered is now inactive and reached its end of lifetime.void
ChannelInboundHandlerAdapter.channelInactive
(ChannelHandlerContext ctx) void
CombinedChannelDuplexHandler.channelInactive
(ChannelHandlerContext ctx) void
DefaultChannelPipeline.HeadContext.channelInactive
(ChannelHandlerContext ctx) void
DefaultChannelPipeline.TailContext.channelInactive
(ChannelHandlerContext ctx) void
ChannelInboundHandler.channelRead
(ChannelHandlerContext ctx, Object msg) Invoked when the currentChannel
has read a message from the peer.void
ChannelInboundHandlerAdapter.channelRead
(ChannelHandlerContext ctx, Object msg) void
CombinedChannelDuplexHandler.channelRead
(ChannelHandlerContext ctx, Object msg) void
DefaultChannelPipeline.HeadContext.channelRead
(ChannelHandlerContext ctx, Object msg) void
DefaultChannelPipeline.TailContext.channelRead
(ChannelHandlerContext ctx, Object msg) void
SimpleChannelInboundHandler.channelRead
(ChannelHandlerContext ctx, Object msg) protected abstract void
SimpleChannelInboundHandler.channelRead0
(ChannelHandlerContext ctx, I msg) Is called for each message of typeSimpleChannelInboundHandler
.void
ChannelInboundHandler.channelReadComplete
(ChannelHandlerContext ctx) Invoked when the last message read by the current read operation has been consumed byChannelInboundHandler.channelRead(ChannelHandlerContext, Object)
.void
ChannelInboundHandlerAdapter.channelReadComplete
(ChannelHandlerContext ctx) CallsfireChannelReadComplete()
to forward to the nextChannelInboundHandler
in theChannelPipeline
.void
CombinedChannelDuplexHandler.channelReadComplete
(ChannelHandlerContext ctx) void
DefaultChannelPipeline.HeadContext.channelReadComplete
(ChannelHandlerContext ctx) void
DefaultChannelPipeline.TailContext.channelReadComplete
(ChannelHandlerContext ctx) void
ChannelInboundHandler.channelRegistered
(ChannelHandlerContext ctx) void
ChannelInboundHandlerAdapter.channelRegistered
(ChannelHandlerContext ctx) final void
ChannelInitializer.channelRegistered
(ChannelHandlerContext ctx) void
CombinedChannelDuplexHandler.channelRegistered
(ChannelHandlerContext ctx) void
DefaultChannelPipeline.HeadContext.channelRegistered
(ChannelHandlerContext ctx) void
DefaultChannelPipeline.TailContext.channelRegistered
(ChannelHandlerContext ctx) void
ChannelInboundHandler.channelUnregistered
(ChannelHandlerContext ctx) void
ChannelInboundHandlerAdapter.channelUnregistered
(ChannelHandlerContext ctx) CallsfireChannelUnregistered()
to forward to the nextChannelInboundHandler
in theChannelPipeline
.void
CombinedChannelDuplexHandler.channelUnregistered
(ChannelHandlerContext ctx) void
DefaultChannelPipeline.HeadContext.channelUnregistered
(ChannelHandlerContext ctx) void
DefaultChannelPipeline.TailContext.channelUnregistered
(ChannelHandlerContext ctx) void
ChannelInboundHandler.channelWritabilityChanged
(ChannelHandlerContext ctx) Gets called once the writable state of aChannel
changed.void
ChannelInboundHandlerAdapter.channelWritabilityChanged
(ChannelHandlerContext ctx) CallsfireChannelWritabilityChanged()
to forward to the nextChannelInboundHandler
in theChannelPipeline
.void
CombinedChannelDuplexHandler.channelWritabilityChanged
(ChannelHandlerContext ctx) void
DefaultChannelPipeline.HeadContext.channelWritabilityChanged
(ChannelHandlerContext ctx) void
DefaultChannelPipeline.TailContext.channelWritabilityChanged
(ChannelHandlerContext ctx) void
ChannelDuplexHandler.close
(ChannelHandlerContext ctx, ChannelPromise promise) CallsChannelOutboundInvoker.close(ChannelPromise)
to forward to the nextChannelOutboundHandler
in theChannelPipeline
.void
ChannelOutboundHandler.close
(ChannelHandlerContext ctx, ChannelPromise promise) Called once a close operation is made.void
ChannelOutboundHandlerAdapter.close
(ChannelHandlerContext ctx, ChannelPromise promise) CallsChannelOutboundInvoker.close(ChannelPromise)
to forward to the nextChannelOutboundHandler
in theChannelPipeline
.void
CombinedChannelDuplexHandler.close
(ChannelHandlerContext ctx, ChannelPromise promise) void
DefaultChannelPipeline.HeadContext.close
(ChannelHandlerContext ctx, ChannelPromise promise) void
ChannelDuplexHandler.connect
(ChannelHandlerContext ctx, SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) CallsChannelOutboundInvoker.connect(SocketAddress, SocketAddress, ChannelPromise)
to forward to the nextChannelOutboundHandler
in theChannelPipeline
.void
ChannelOutboundHandler.connect
(ChannelHandlerContext ctx, SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) Called once a connect operation is made.void
ChannelOutboundHandlerAdapter.connect
(ChannelHandlerContext ctx, SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) CallsChannelOutboundInvoker.connect(SocketAddress, SocketAddress, ChannelPromise)
to forward to the nextChannelOutboundHandler
in theChannelPipeline
.void
CombinedChannelDuplexHandler.connect
(ChannelHandlerContext ctx, SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) void
DefaultChannelPipeline.HeadContext.connect
(ChannelHandlerContext ctx, SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) void
ChannelDuplexHandler.deregister
(ChannelHandlerContext ctx, ChannelPromise promise) CallsChannelOutboundInvoker.deregister(ChannelPromise)
to forward to the nextChannelOutboundHandler
in theChannelPipeline
.void
ChannelOutboundHandler.deregister
(ChannelHandlerContext ctx, ChannelPromise promise) Called once a deregister operation is made from the current registeredEventLoop
.void
ChannelOutboundHandlerAdapter.deregister
(ChannelHandlerContext ctx, ChannelPromise promise) CallsChannelOutboundInvoker.deregister(ChannelPromise)
to forward to the nextChannelOutboundHandler
in theChannelPipeline
.void
CombinedChannelDuplexHandler.deregister
(ChannelHandlerContext ctx, ChannelPromise promise) void
DefaultChannelPipeline.HeadContext.deregister
(ChannelHandlerContext ctx, ChannelPromise promise) void
ChannelDuplexHandler.disconnect
(ChannelHandlerContext ctx, ChannelPromise promise) CallsChannelOutboundInvoker.disconnect(ChannelPromise)
to forward to the nextChannelOutboundHandler
in theChannelPipeline
.void
ChannelOutboundHandler.disconnect
(ChannelHandlerContext ctx, ChannelPromise promise) Called once a disconnect operation is made.void
ChannelOutboundHandlerAdapter.disconnect
(ChannelHandlerContext ctx, ChannelPromise promise) CallsChannelOutboundInvoker.disconnect(ChannelPromise)
to forward to the nextChannelOutboundHandler
in theChannelPipeline
.void
CombinedChannelDuplexHandler.disconnect
(ChannelHandlerContext ctx, ChannelPromise promise) void
DefaultChannelPipeline.HeadContext.disconnect
(ChannelHandlerContext ctx, ChannelPromise promise) protected abstract void
SimpleUserEventChannelHandler.eventReceived
(ChannelHandlerContext ctx, I evt) Is called for each user event triggered of typeSimpleUserEventChannelHandler
.void
ChannelHandler.exceptionCaught
(ChannelHandlerContext ctx, Throwable cause) Deprecated.void
ChannelHandlerAdapter.exceptionCaught
(ChannelHandlerContext ctx, Throwable cause) Deprecated.is part ofChannelInboundHandler
void
ChannelInboundHandler.exceptionCaught
(ChannelHandlerContext ctx, Throwable cause) Gets called if aThrowable
was thrown.void
ChannelInboundHandlerAdapter.exceptionCaught
(ChannelHandlerContext ctx, Throwable cause) void
ChannelInitializer.exceptionCaught
(ChannelHandlerContext ctx, Throwable cause) void
CombinedChannelDuplexHandler.exceptionCaught
(ChannelHandlerContext ctx, Throwable cause) void
DefaultChannelPipeline.HeadContext.exceptionCaught
(ChannelHandlerContext ctx, Throwable cause) void
DefaultChannelPipeline.TailContext.exceptionCaught
(ChannelHandlerContext ctx, Throwable cause) void
ChannelDuplexHandler.flush
(ChannelHandlerContext ctx) void
ChannelOutboundHandler.flush
(ChannelHandlerContext ctx) Called once a flush operation is made.void
ChannelOutboundHandlerAdapter.flush
(ChannelHandlerContext ctx) void
CombinedChannelDuplexHandler.flush
(ChannelHandlerContext ctx) void
DefaultChannelPipeline.HeadContext.flush
(ChannelHandlerContext ctx) void
ChannelHandler.handlerAdded
(ChannelHandlerContext ctx) Gets called after theChannelHandler
was added to the actual context and it's ready to handle events.void
ChannelHandlerAdapter.handlerAdded
(ChannelHandlerContext ctx) Do nothing by default, sub-classes may override this method.void
ChannelInitializer.handlerAdded
(ChannelHandlerContext ctx) Do nothing by default, sub-classes may override this method.void
CombinedChannelDuplexHandler.handlerAdded
(ChannelHandlerContext ctx) void
DefaultChannelPipeline.HeadContext.handlerAdded
(ChannelHandlerContext ctx) void
DefaultChannelPipeline.TailContext.handlerAdded
(ChannelHandlerContext ctx) void
ChannelHandler.handlerRemoved
(ChannelHandlerContext ctx) Gets called after theChannelHandler
was removed from the actual context and it doesn't handle events anymore.void
ChannelHandlerAdapter.handlerRemoved
(ChannelHandlerContext ctx) Do nothing by default, sub-classes may override this method.void
ChannelInitializer.handlerRemoved
(ChannelHandlerContext ctx) void
CombinedChannelDuplexHandler.handlerRemoved
(ChannelHandlerContext ctx) void
DefaultChannelPipeline.HeadContext.handlerRemoved
(ChannelHandlerContext ctx) void
DefaultChannelPipeline.TailContext.handlerRemoved
(ChannelHandlerContext ctx) private boolean
ChannelInitializer.initChannel
(ChannelHandlerContext ctx) protected void
DefaultChannelPipeline.onUnhandledInboundMessage
(ChannelHandlerContext ctx, Object msg) Called once a message hit the end of theChannelPipeline
without been handled by the user inChannelInboundHandler.channelRead(ChannelHandlerContext, Object)
.void
ChannelDuplexHandler.read
(ChannelHandlerContext ctx) void
ChannelOutboundHandler.read
(ChannelHandlerContext ctx) Interceptsread()
.void
ChannelOutboundHandlerAdapter.read
(ChannelHandlerContext ctx) void
CombinedChannelDuplexHandler.read
(ChannelHandlerContext ctx) void
DefaultChannelPipeline.HeadContext.read
(ChannelHandlerContext ctx) private <T extends ChannelHandler>
TDefaultChannelPipeline.removeIfExists
(ChannelHandlerContext ctx) private void
ChannelInitializer.removeState
(ChannelHandlerContext ctx) void
ChannelInboundHandler.userEventTriggered
(ChannelHandlerContext ctx, Object evt) Gets called if an user event was triggered.void
ChannelInboundHandlerAdapter.userEventTriggered
(ChannelHandlerContext ctx, Object evt) CallsfireUserEventTriggered(Object)
to forward to the nextChannelInboundHandler
in theChannelPipeline
.void
CombinedChannelDuplexHandler.userEventTriggered
(ChannelHandlerContext ctx, Object evt) void
DefaultChannelPipeline.HeadContext.userEventTriggered
(ChannelHandlerContext ctx, Object evt) void
DefaultChannelPipeline.TailContext.userEventTriggered
(ChannelHandlerContext ctx, Object evt) final void
SimpleUserEventChannelHandler.userEventTriggered
(ChannelHandlerContext ctx, Object evt) void
ChannelDuplexHandler.write
(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) CallsChannelOutboundInvoker.write(Object, ChannelPromise)
to forward to the nextChannelOutboundHandler
in theChannelPipeline
.void
ChannelOutboundHandler.write
(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) Called once a write operation is made.void
ChannelOutboundHandlerAdapter.write
(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) CallsChannelOutboundInvoker.write(Object, ChannelPromise)
to forward to the nextChannelOutboundHandler
in theChannelPipeline
.void
CombinedChannelDuplexHandler.write
(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) void
DefaultChannelPipeline.HeadContext.write
(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) final void
AbstractCoalescingBufferQueue.writeAndRemoveAll
(ChannelHandlerContext ctx) Writes all remaining elements in this queue.Constructors in io.netty.channel with parameters of type ChannelHandlerContextModifierConstructorDescription(package private)
-
Uses of ChannelHandlerContext in io.netty.channel.embedded
Methods in io.netty.channel.embedded with parameters of type ChannelHandlerContextModifier and TypeMethodDescriptionprotected void
EmbeddedChannel.EmbeddedChannelPipeline.onUnhandledInboundMessage
(ChannelHandlerContext ctx, Object msg) -
Uses of ChannelHandlerContext in io.netty.handler.address
Methods in io.netty.handler.address with parameters of type ChannelHandlerContextModifier and TypeMethodDescriptionfinal void
DynamicAddressConnectHandler.connect
(ChannelHandlerContext ctx, SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) void
ResolveAddressHandler.connect
(ChannelHandlerContext ctx, SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) -
Uses of ChannelHandlerContext in io.netty.handler.codec
Fields in io.netty.handler.codec declared as ChannelHandlerContextMethods in io.netty.handler.codec that return ChannelHandlerContextMethods in io.netty.handler.codec with parameters of type ChannelHandlerContextModifier and TypeMethodDescriptionprotected ByteBuf
MessageToByteEncoder.allocateBuffer
(ChannelHandlerContext ctx, I msg, boolean preferDirect) Allocate aByteBuf
which will be used as argument ofMessageToByteEncoder.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 givenByteBuf
.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) private void
ByteToMessageDecoder.channelInputClosed
(ChannelHandlerContext ctx, boolean callChannelInactive) (package private) void
ByteToMessageDecoder.channelInputClosed
(ChannelHandlerContext ctx, List<Object> out) Called when the input of the channel was closed which may be because it changed to inactive or because ofChannelInputShutdownEvent
.(package private) final void
ReplayingDecoder.channelInputClosed
(ChannelHandlerContext ctx, List<Object> out) void
ByteToMessageCodec.channelRead
(ChannelHandlerContext ctx, Object msg) void
ByteToMessageDecoder.channelRead
(ChannelHandlerContext ctx, Object msg) void
MessageToMessageCodec.channelRead
(ChannelHandlerContext ctx, Object msg) void
MessageToMessageDecoder.channelRead
(ChannelHandlerContext ctx, Object msg) void
ByteToMessageCodec.channelReadComplete
(ChannelHandlerContext ctx) void
ByteToMessageDecoder.channelReadComplete
(ChannelHandlerContext ctx) void
DatagramPacketDecoder.channelReadComplete
(ChannelHandlerContext ctx) void
MessageAggregator.channelReadComplete
(ChannelHandlerContext ctx) void
MessageToMessageCodec.channelReadComplete
(ChannelHandlerContext ctx) void
MessageToMessageDecoder.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 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 oneByteBuf
to an other.protected void
DatagramPacketDecoder.decode
(ChannelHandlerContext ctx, DatagramPacket msg, List<Object> out) protected Object
DelimiterBasedFrameDecoder.decode
(ChannelHandlerContext ctx, ByteBuf buffer) Create a frame out of theByteBuf
and return it.protected final void
DelimiterBasedFrameDecoder.decode
(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) protected Object
FixedLengthFrameDecoder.decode
(ChannelHandlerContext ctx, ByteBuf in) Create a frame out of theByteBuf
and return it.protected final void
FixedLengthFrameDecoder.decode
(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) protected Object
LengthFieldBasedFrameDecoder.decode
(ChannelHandlerContext ctx, ByteBuf in) Create a frame out of theByteBuf
and return it.protected final void
LengthFieldBasedFrameDecoder.decode
(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) protected Object
LineBasedFrameDecoder.decode
(ChannelHandlerContext ctx, ByteBuf buffer) Create a frame out of theByteBuf
and return it.protected final void
LineBasedFrameDecoder.decode
(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) 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 abstract void
MessageToMessageDecoder.decode
(ChannelHandlerContext ctx, I msg, List<Object> out) Decode from one message to an other.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 theChannelHandlerContext
goes in-active.(package private) final void
ByteToMessageDecoder.decodeRemovalReentryProtection
(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) Decode the from oneByteBuf
to an other.void
DatagramPacketEncoder.deregister
(ChannelHandlerContext ctx, ChannelPromise promise) void
DatagramPacketEncoder.disconnect
(ChannelHandlerContext ctx, ChannelPromise promise) protected abstract void
ByteToMessageCodec.encode
(ChannelHandlerContext ctx, I msg, ByteBuf out) protected void
ByteToMessageCodec.Encoder.encode
(ChannelHandlerContext ctx, I msg, ByteBuf out) protected void
DatagramPacketEncoder.encode
(ChannelHandlerContext ctx, AddressedEnvelope<M, InetSocketAddress> msg, List<Object> out) protected void
LengthFieldPrepender.encode
(ChannelHandlerContext ctx, ByteBuf msg, List<Object> out) protected abstract void
MessageToByteEncoder.encode
(ChannelHandlerContext ctx, I msg, ByteBuf out) Encode a message into aByteBuf
.protected abstract void
MessageToMessageCodec.encode
(ChannelHandlerContext ctx, OUTBOUND_IN msg, List<Object> out) protected abstract void
MessageToMessageEncoder.encode
(ChannelHandlerContext ctx, I msg, List<Object> out) Encode from one message to an other.void
DatagramPacketDecoder.exceptionCaught
(ChannelHandlerContext ctx, Throwable cause) void
DatagramPacketEncoder.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.private void
LineBasedFrameDecoder.fail
(ChannelHandlerContext ctx, int length) private void
LineBasedFrameDecoder.fail
(ChannelHandlerContext ctx, String length) (package private) static void
ByteToMessageDecoder.fireChannelRead
(ChannelHandlerContext ctx, CodecOutputList msgs, int numElements) GetnumElements
out of theCodecOutputList
and forward these through the pipeline.(package private) static void
ByteToMessageDecoder.fireChannelRead
(ChannelHandlerContext ctx, List<Object> msgs, int numElements) GetnumElements
out of theList
and forward these through the pipeline.void
DatagramPacketEncoder.flush
(ChannelHandlerContext ctx) protected void
MessageAggregator.handleOversizedMessage
(ChannelHandlerContext ctx, S oversized) Invoked when an incoming request exceeds the maximum content length.void
ByteToMessageCodec.handlerAdded
(ChannelHandlerContext ctx) void
DatagramPacketDecoder.handlerAdded
(ChannelHandlerContext ctx) void
DatagramPacketEncoder.handlerAdded
(ChannelHandlerContext ctx) void
MessageAggregator.handlerAdded
(ChannelHandlerContext ctx) void
ByteToMessageCodec.handlerRemoved
(ChannelHandlerContext ctx) final void
ByteToMessageDecoder.handlerRemoved
(ChannelHandlerContext ctx) void
DatagramPacketDecoder.handlerRemoved
(ChannelHandlerContext ctx) void
DatagramPacketEncoder.handlerRemoved
(ChannelHandlerContext ctx) void
MessageAggregator.handlerRemoved
(ChannelHandlerContext ctx) protected void
ByteToMessageDecoder.handlerRemoved0
(ChannelHandlerContext ctx) Gets called after theByteToMessageDecoder
was removed from the actual context and it doesn't handle events anymore.private void
MessageAggregator.invokeHandleOversizedMessage
(ChannelHandlerContext ctx, S oversized) void
DatagramPacketEncoder.read
(ChannelHandlerContext ctx) void
ByteToMessageDecoder.userEventTriggered
(ChannelHandlerContext ctx, Object evt) void
DatagramPacketDecoder.userEventTriggered
(ChannelHandlerContext ctx, Object evt) void
ByteToMessageCodec.write
(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) void
MessageToByteEncoder.write
(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) void
MessageToMessageCodec.write
(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) void
MessageToMessageEncoder.write
(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) private static void
MessageToMessageEncoder.writePromiseCombiner
(ChannelHandlerContext ctx, CodecOutputList out, ChannelPromise promise) private static void
MessageToMessageEncoder.writeVoidPromise
(ChannelHandlerContext ctx, CodecOutputList out) -
Uses of ChannelHandlerContext in io.netty.handler.codec.base64
Methods in io.netty.handler.codec.base64 with parameters of type ChannelHandlerContextModifier and TypeMethodDescriptionprotected void
Base64Decoder.decode
(ChannelHandlerContext ctx, ByteBuf msg, List<Object> out) protected void
Base64Encoder.encode
(ChannelHandlerContext ctx, ByteBuf msg, List<Object> out) -
Uses of ChannelHandlerContext in io.netty.handler.codec.bytes
Methods in io.netty.handler.codec.bytes with parameters of type ChannelHandlerContextModifier and TypeMethodDescriptionprotected void
ByteArrayDecoder.decode
(ChannelHandlerContext ctx, ByteBuf msg, List<Object> out) protected void
ByteArrayEncoder.encode
(ChannelHandlerContext ctx, byte[] msg, List<Object> out) -
Uses of ChannelHandlerContext in io.netty.handler.codec.compression
Fields in io.netty.handler.codec.compression declared as ChannelHandlerContextModifier and TypeFieldDescriptionprivate ChannelHandlerContext
Bzip2Encoder.ctx
Used to interact with itsChannelPipeline
and other handlers.private ChannelHandlerContext
JdkZlibEncoder.ctx
private ChannelHandlerContext
JZlibEncoder.ctx
Methods in io.netty.handler.codec.compression that return ChannelHandlerContextModifier and TypeMethodDescriptionprivate ChannelHandlerContext
Bzip2Encoder.ctx()
private ChannelHandlerContext
JdkZlibEncoder.ctx()
private ChannelHandlerContext
JZlibEncoder.ctx()
Methods in io.netty.handler.codec.compression with parameters of type ChannelHandlerContextModifier and TypeMethodDescriptionprotected final ByteBuf
JdkZlibEncoder.allocateBuffer
(ChannelHandlerContext ctx, ByteBuf msg, boolean preferDirect) void
Bzip2Encoder.close
(ChannelHandlerContext ctx, ChannelPromise promise) void
JdkZlibEncoder.close
(ChannelHandlerContext ctx, ChannelPromise promise) void
JZlibEncoder.close
(ChannelHandlerContext ctx, ChannelPromise promise) (package private) static void
EncoderUtil.closeAfterFinishEncode
(ChannelHandlerContext ctx, ChannelFuture finishFuture, ChannelPromise promise) protected void
Bzip2Decoder.decode
(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) protected void
FastLzFrameDecoder.decode
(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) protected void
JdkZlibDecoder.decode
(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) protected void
JZlibDecoder.decode
(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) protected void
SnappyFrameDecoder.decode
(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) protected void
Bzip2Encoder.encode
(ChannelHandlerContext ctx, ByteBuf in, ByteBuf out) protected void
FastLzFrameEncoder.encode
(ChannelHandlerContext ctx, ByteBuf in, ByteBuf out) protected void
JdkZlibEncoder.encode
(ChannelHandlerContext ctx, ByteBuf uncompressed, ByteBuf out) protected void
JZlibEncoder.encode
(ChannelHandlerContext ctx, ByteBuf in, ByteBuf out) protected void
SnappyFrameEncoder.encode
(ChannelHandlerContext ctx, ByteBuf in, ByteBuf out) private ChannelFuture
Bzip2Encoder.finishEncode
(ChannelHandlerContext ctx, ChannelPromise promise) private ChannelFuture
JdkZlibEncoder.finishEncode
(ChannelHandlerContext ctx, ChannelPromise promise) private ChannelFuture
JZlibEncoder.finishEncode
(ChannelHandlerContext ctx, ChannelPromise promise) void
Bzip2Encoder.handlerAdded
(ChannelHandlerContext ctx) void
JdkZlibEncoder.handlerAdded
(ChannelHandlerContext ctx) void
JZlibEncoder.handlerAdded
(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. -
Uses of ChannelHandlerContext in io.netty.handler.codec.dns
Methods in io.netty.handler.codec.dns with parameters of type ChannelHandlerContextModifier and TypeMethodDescriptionprotected ByteBuf
DatagramDnsQueryEncoder.allocateBuffer
(ChannelHandlerContext ctx, AddressedEnvelope<DnsQuery, InetSocketAddress> msg) Allocate aByteBuf
which will be used for constructing a datagram packet.protected ByteBuf
DatagramDnsResponseEncoder.allocateBuffer
(ChannelHandlerContext ctx, AddressedEnvelope<DnsResponse, InetSocketAddress> msg) Allocate aByteBuf
which will be used for constructing a datagram packet.protected ByteBuf
TcpDnsQueryEncoder.allocateBuffer
(ChannelHandlerContext ctx, DnsQuery msg, boolean preferDirect) protected void
DatagramDnsQueryDecoder.decode
(ChannelHandlerContext ctx, DatagramPacket packet, List<Object> out) protected void
DatagramDnsResponseDecoder.decode
(ChannelHandlerContext ctx, DatagramPacket packet, List<Object> out) protected Object
TcpDnsQueryDecoder.decode
(ChannelHandlerContext ctx, ByteBuf in) protected Object
TcpDnsResponseDecoder.decode
(ChannelHandlerContext ctx, ByteBuf in) 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) -
Uses of ChannelHandlerContext in io.netty.handler.codec.haproxy
Methods in io.netty.handler.codec.haproxy with parameters of type ChannelHandlerContextModifier and TypeMethodDescriptionvoid
HAProxyMessageDecoder.channelRead
(ChannelHandlerContext ctx, Object msg) protected final void
HAProxyMessageDecoder.decode
(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) private ByteBuf
HAProxyMessageDecoder.decodeLine
(ChannelHandlerContext ctx, ByteBuf buffer) Create a frame out of theByteBuf
and return it.private ByteBuf
HAProxyMessageDecoder.decodeStruct
(ChannelHandlerContext ctx, ByteBuf buffer) Create a frame out of theByteBuf
and return it.protected void
HAProxyMessageEncoder.encode
(ChannelHandlerContext ctx, HAProxyMessage msg, ByteBuf out) HAProxyMessageDecoder.HeaderExtractor.extract
(ChannelHandlerContext ctx, ByteBuf buffer) Create a frame out of theByteBuf
and return it.private void
HAProxyMessageDecoder.fail
(ChannelHandlerContext ctx, String errMsg, Exception e) private void
HAProxyMessageDecoder.failOverLimit
(ChannelHandlerContext ctx, int length) private void
HAProxyMessageDecoder.failOverLimit
(ChannelHandlerContext ctx, String length) -
Uses of ChannelHandlerContext in io.netty.handler.codec.http
Fields in io.netty.handler.codec.http declared as ChannelHandlerContextModifier and TypeFieldDescriptionprivate ChannelHandlerContext
HttpContentCompressor.ctx
protected ChannelHandlerContext
HttpContentDecoder.ctx
Methods in io.netty.handler.codec.http with parameters of type ChannelHandlerContextModifier and TypeMethodDescriptionprivate static void
HttpObjectEncoder.addEncodedLengthHex
(ChannelHandlerContext ctx, long contentLength, List<Object> out) void
HttpClientUpgradeHandler.bind
(ChannelHandlerContext ctx, SocketAddress localAddress, ChannelPromise promise) void
HttpClientCodec.Decoder.channelInactive
(ChannelHandlerContext ctx) void
HttpContentDecoder.channelInactive
(ChannelHandlerContext ctx) void
HttpContentEncoder.channelInactive
(ChannelHandlerContext ctx) void
HttpServerExpectContinueHandler.channelRead
(ChannelHandlerContext ctx, Object msg) void
HttpServerKeepAliveHandler.channelRead
(ChannelHandlerContext ctx, Object msg) void
HttpContentDecoder.channelReadComplete
(ChannelHandlerContext ctx) private void
HttpContentDecoder.cleanupSafely
(ChannelHandlerContext ctx) private void
HttpContentEncoder.cleanupSafely
(ChannelHandlerContext ctx) void
HttpClientUpgradeHandler.close
(ChannelHandlerContext ctx, ChannelPromise promise) void
HttpClientUpgradeHandler.connect
(ChannelHandlerContext ctx, SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) protected void
HttpClientCodec.Decoder.decode
(ChannelHandlerContext ctx, ByteBuf buffer, List<Object> out) protected void
HttpClientUpgradeHandler.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.decode
(ChannelHandlerContext ctx, ByteBuf buffer, List<Object> out) protected void
HttpServerCodec.HttpServerRequestDecoder.decode
(ChannelHandlerContext ctx, ByteBuf buffer, List<Object> out) protected void
HttpServerUpgradeHandler.decode
(ChannelHandlerContext ctx, HttpObject 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
HttpClientCodec.Encoder.encode
(ChannelHandlerContext ctx, Object msg, List<Object> out) protected void
HttpContentEncoder.encode
(ChannelHandlerContext ctx, HttpObject msg, List<Object> out) protected void
HttpObjectEncoder.encode
(ChannelHandlerContext ctx, Object msg, List<Object> out) private void
HttpObjectEncoder.encodeByteBufAndTrailers
(int state, ChannelHandlerContext ctx, List<Object> out, ByteBuf content, HttpHeaders trailingHeaders) private void
HttpObjectEncoder.encodeByteBufContent
(ChannelHandlerContext ctx, ByteBuf content, List<Object> out) private void
HttpObjectEncoder.encodeByteBufHttpContent
(int state, ChannelHandlerContext ctx, ByteBuf buf, ByteBuf content, HttpHeaders trailingHeaders, List<Object> out) private void
HttpObjectEncoder.encodeChunkedHttpContent
(ChannelHandlerContext ctx, ByteBuf content, HttpHeaders trailingHeaders, List<Object> out) private static void
HttpObjectEncoder.encodedChunkedFileRegionContent
(ChannelHandlerContext ctx, FileRegion msg, List<Object> out) private void
HttpObjectEncoder.encodeFileRegionContent
(ChannelHandlerContext ctx, FileRegion msg, List<Object> out) private void
HttpObjectEncoder.encodeFullHttpMessage
(ChannelHandlerContext ctx, Object o, List<Object> out) private void
HttpObjectEncoder.encodeHttpContent
(ChannelHandlerContext ctx, HttpContent msg, List<Object> out) private void
HttpObjectEncoder.encodeHttpMessageLastContent
(ChannelHandlerContext ctx, H m, List<Object> out) private void
HttpObjectEncoder.encodeHttpMessageNotLastContent
(ChannelHandlerContext ctx, H m, List<Object> out) private ByteBuf
HttpObjectEncoder.encodeInitHttpMessage
(ChannelHandlerContext ctx, H m) private void
HttpObjectEncoder.encodeJustHttpMessage
(ChannelHandlerContext ctx, H m, List<Object> out) private void
HttpObjectEncoder.encodeLastHttpContent
(ChannelHandlerContext ctx, LastHttpContent msg, List<Object> out) private void
HttpObjectEncoder.encodeNotHttpMessageContentTypes
(ChannelHandlerContext ctx, Object msg, List<Object> out) private void
HttpObjectEncoder.encodeTrailingHeaders
(ChannelHandlerContext ctx, HttpHeaders trailingHeaders, List<Object> out) void
HttpClientUpgradeHandler.flush
(ChannelHandlerContext ctx) protected void
HttpObjectAggregator.handleOversizedMessage
(ChannelHandlerContext ctx, HttpMessage oversized) void
HttpContentCompressor.handlerAdded
(ChannelHandlerContext ctx) void
HttpContentDecoder.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 theHttpClientUpgradeHandler.UpgradeCodec
can send an initial greeting (if any).boolean
HttpServerUpgradeHandler.UpgradeCodec.prepareUpgradeResponse
(ChannelHandlerContext ctx, FullHttpRequest upgradeRequest, HttpHeaders upgradeHeaders) Prepares theupgradeHeaders
for a protocol update based upon the contents ofupgradeRequest
.void
HttpClientUpgradeHandler.read
(ChannelHandlerContext ctx) HttpChunkedInput.readChunk
(ChannelHandlerContext ctx) Deprecated.private static void
HttpClientUpgradeHandler.removeThisHandler
(ChannelHandlerContext ctx) HttpClientUpgradeHandler.UpgradeCodec.setUpgradeHeaders
(ChannelHandlerContext ctx, HttpRequest upgradeRequest) Sets any protocol-specific headers required to the upgrade request.private void
HttpClientUpgradeHandler.setUpgradeRequestHeaders
(ChannelHandlerContext ctx, HttpRequest request) Adds all upgrade request headers necessary for an upgrade to the supported protocols.private boolean
HttpServerUpgradeHandler.upgrade
(ChannelHandlerContext ctx, FullHttpRequest request) Attempts to upgrade to the protocol(s) identified by theHttpHeaderNames.UPGRADE
header (if provided in the request).void
HttpClientCodec.upgradeFrom
(ChannelHandlerContext ctx) Upgrades to another protocol from HTTP.void
HttpClientUpgradeHandler.SourceCodec.upgradeFrom
(ChannelHandlerContext ctx) Removes this codec (i.e.void
HttpServerCodec.upgradeFrom
(ChannelHandlerContext ctx) Upgrades to another protocol from HTTP.void
HttpServerUpgradeHandler.SourceCodec.upgradeFrom
(ChannelHandlerContext ctx) Removes this codec (i.e.void
HttpClientUpgradeHandler.UpgradeCodec.upgradeTo
(ChannelHandlerContext ctx, FullHttpResponse upgradeResponse) Performs an HTTP protocol upgrade from the source codec.void
HttpServerUpgradeHandler.UpgradeCodec.upgradeTo
(ChannelHandlerContext ctx, FullHttpRequest upgradeRequest) Performs an HTTP protocol upgrade from the source codec.void
HttpObjectDecoder.userEventTriggered
(ChannelHandlerContext ctx, Object evt) void
HttpClientUpgradeHandler.write
(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) void
HttpObjectEncoder.write
(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) void
HttpServerKeepAliveHandler.write
(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) private static void
HttpObjectEncoder.writeOutList
(ChannelHandlerContext ctx, List<Object> out, ChannelPromise promise) private static void
HttpObjectEncoder.writePromiseCombiner
(ChannelHandlerContext ctx, List<Object> out, ChannelPromise promise) private static void
HttpObjectEncoder.writeVoidPromise
(ChannelHandlerContext ctx, List<Object> out) -
Uses of ChannelHandlerContext in io.netty.handler.codec.http.cors
Methods in io.netty.handler.codec.http.cors with parameters of type ChannelHandlerContextModifier and TypeMethodDescriptionvoid
CorsHandler.channelRead
(ChannelHandlerContext ctx, Object msg) private static void
CorsHandler.forbidden
(ChannelHandlerContext ctx, HttpRequest request) private void
CorsHandler.handlePreflight
(ChannelHandlerContext ctx, HttpRequest request) private static void
CorsHandler.respond
(ChannelHandlerContext ctx, HttpRequest request, HttpResponse response) void
CorsHandler.write
(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) -
Uses of ChannelHandlerContext in io.netty.handler.codec.http.multipart
Methods in io.netty.handler.codec.http.multipart with parameters of type ChannelHandlerContextModifier and TypeMethodDescriptionHttpPostRequestEncoder.readChunk
(ChannelHandlerContext ctx) Deprecated. -
Uses of ChannelHandlerContext in io.netty.handler.codec.http.websocketx
Fields in io.netty.handler.codec.http.websocketx declared as ChannelHandlerContextModifier and TypeFieldDescriptionprivate ChannelHandlerContext
WebSocketClientProtocolHandshakeHandler.ctx
private ChannelHandlerContext
WebSocketServerProtocolHandshakeHandler.ctx
Methods in io.netty.handler.codec.http.websocketx with parameters of type ChannelHandlerContextModifier and TypeMethodDescriptionprivate void
WebSocketProtocolHandler.applyCloseSentTimeout
(ChannelHandlerContext ctx) void
WebSocketProtocolHandler.bind
(ChannelHandlerContext ctx, SocketAddress localAddress, ChannelPromise promise) void
WebSocketClientProtocolHandshakeHandler.channelActive
(ChannelHandlerContext ctx) void
WebSocketClientProtocolHandshakeHandler.channelInactive
(ChannelHandlerContext ctx) void
Utf8FrameValidator.channelRead
(ChannelHandlerContext ctx, Object msg) void
WebSocketClientProtocolHandshakeHandler.channelRead
(ChannelHandlerContext ctx, Object msg) void
WebSocketServerProtocolHandshakeHandler.channelRead
(ChannelHandlerContext ctx, Object msg) protected void
WebSocket08FrameDecoder.checkCloseFrameBody
(ChannelHandlerContext ctx, ByteBuf buffer) WebSocketClientHandshaker.close
(ChannelHandlerContext ctx, CloseWebSocketFrame frame) Performs the closing handshakeWebSocketClientHandshaker.close
(ChannelHandlerContext ctx, CloseWebSocketFrame frame, ChannelPromise promise) Performs the closing handshakevoid
WebSocketProtocolHandler.close
(ChannelHandlerContext ctx, ChannelPromise promise) WebSocketServerHandshaker.close
(ChannelHandlerContext ctx, CloseWebSocketFrame frame) Performs the closing handshake.WebSocketServerHandshaker.close
(ChannelHandlerContext ctx, CloseWebSocketFrame frame, ChannelPromise promise) Performs the closing handshake.WebSocketServerHandshaker00.close
(ChannelHandlerContext ctx, CloseWebSocketFrame frame, ChannelPromise promise) Echo back the closing framevoid
WebSocketProtocolHandler.connect
(ChannelHandlerContext ctx, SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) protected void
WebSocket00FrameDecoder.decode
(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) protected void
WebSocket08FrameDecoder.decode
(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) protected void
WebSocketClientProtocolHandler.decode
(ChannelHandlerContext ctx, WebSocketFrame frame, List<Object> out) protected void
WebSocketProtocolHandler.decode
(ChannelHandlerContext ctx, WebSocketFrame frame, List<Object> out) protected void
WebSocketServerProtocolHandler.decode
(ChannelHandlerContext ctx, WebSocketFrame frame, List<Object> out) private WebSocketFrame
WebSocket00FrameDecoder.decodeBinaryFrame
(ChannelHandlerContext ctx, byte type, ByteBuf buffer) private WebSocketFrame
WebSocket00FrameDecoder.decodeTextFrame
(ChannelHandlerContext ctx, ByteBuf buffer) void
WebSocketProtocolHandler.deregister
(ChannelHandlerContext ctx, ChannelPromise promise) void
WebSocketProtocolHandler.disconnect
(ChannelHandlerContext ctx, ChannelPromise promise) 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
WebSocketProtocolHandler.exceptionCaught
(ChannelHandlerContext ctx, Throwable cause) void
WebSocketServerProtocolHandler.exceptionCaught
(ChannelHandlerContext ctx, Throwable cause) void
WebSocketProtocolHandler.flush
(ChannelHandlerContext ctx) void
WebSocketClientProtocolHandler.handlerAdded
(ChannelHandlerContext ctx) void
WebSocketClientProtocolHandshakeHandler.handlerAdded
(ChannelHandlerContext ctx) void
WebSocketServerProtocolHandler.handlerAdded
(ChannelHandlerContext ctx) void
WebSocketServerProtocolHandshakeHandler.handlerAdded
(ChannelHandlerContext ctx) private void
Utf8FrameValidator.protocolViolation
(ChannelHandlerContext ctx, WebSocketFrame frame, CorruptedWebSocketFrameException ex) private void
WebSocket08FrameDecoder.protocolViolation
(ChannelHandlerContext ctx, ByteBuf in, CorruptedWebSocketFrameException ex) private void
WebSocket08FrameDecoder.protocolViolation
(ChannelHandlerContext ctx, ByteBuf in, WebSocketCloseStatus status, String reason) private void
WebSocket08FrameDecoder.protocolViolation
(ChannelHandlerContext ctx, ByteBuf in, String reason) void
WebSocketProtocolHandler.read
(ChannelHandlerContext ctx) WebSocketChunkedInput.readChunk
(ChannelHandlerContext ctx) Deprecated.private static void
WebSocketProtocolHandler.readIfNeeded
(ChannelHandlerContext ctx) private static void
WebSocketServerProtocolHandshakeHandler.sendHttpResponse
(ChannelHandlerContext ctx, HttpRequest req, HttpResponse res) void
WebSocketProtocolHandler.write
(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) -
Uses of ChannelHandlerContext in io.netty.handler.codec.http.websocketx.extensions
Methods in io.netty.handler.codec.http.websocketx.extensions with parameters of type ChannelHandlerContextModifier and TypeMethodDescriptionvoid
WebSocketClientExtensionHandler.channelRead
(ChannelHandlerContext ctx, Object msg) void
WebSocketServerExtensionHandler.channelRead
(ChannelHandlerContext ctx, Object msg) private void
WebSocketServerExtensionHandler.handlePotentialUpgrade
(ChannelHandlerContext ctx, ChannelPromise promise, HttpResponse httpResponse, List<WebSocketServerExtension> validExtensionsList) 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) -
Uses of ChannelHandlerContext in io.netty.handler.codec.http.websocketx.extensions.compression
Methods in io.netty.handler.codec.http.websocketx.extensions.compression with parameters of type ChannelHandlerContextModifier and TypeMethodDescriptionvoid
DeflateDecoder.channelInactive
(ChannelHandlerContext ctx) private ByteBuf
DeflateEncoder.compressContent
(ChannelHandlerContext ctx, WebSocketFrame msg) protected void
DeflateDecoder.decode
(ChannelHandlerContext ctx, WebSocketFrame msg, List<Object> out) protected void
PerMessageDeflateDecoder.decode
(ChannelHandlerContext ctx, WebSocketFrame msg, List<Object> out) private ByteBuf
DeflateDecoder.decompressContent
(ChannelHandlerContext ctx, WebSocketFrame msg) protected void
DeflateEncoder.encode
(ChannelHandlerContext ctx, WebSocketFrame msg, List<Object> out) protected void
PerMessageDeflateEncoder.encode
(ChannelHandlerContext ctx, WebSocketFrame msg, List<Object> out) void
DeflateDecoder.handlerRemoved
(ChannelHandlerContext ctx) void
DeflateEncoder.handlerRemoved
(ChannelHandlerContext ctx) -
Uses of ChannelHandlerContext in io.netty.handler.codec.http2
Fields in io.netty.handler.codec.http2 declared as ChannelHandlerContextModifier and TypeFieldDescriptionprivate ChannelHandlerContext
DefaultHttp2LocalFlowController.ctx
private ChannelHandlerContext
DefaultHttp2RemoteFlowController.ctx
private final ChannelHandlerContext
Http2ConnectionHandler.ClosingChannelFutureListener.ctx
(package private) ChannelHandlerContext
Http2FrameCodec.ctx
(package private) ChannelHandlerContext
Http2MultiplexCodec.ctx
Deprecated.private ChannelHandlerContext
Http2MultiplexHandler.ctx
(package private) final ChannelHandlerContext
StreamBufferingEncoder.PendingStream.ctx
private ChannelHandlerContext
Http2StreamChannelBootstrap.multiplexCtx
Methods in io.netty.handler.codec.http2 that return ChannelHandlerContextModifier and TypeMethodDescriptionDefaultHttp2RemoteFlowController.channelHandlerContext()
Http2RemoteFlowController.channelHandlerContext()
Get theChannelHandlerContext
for which to apply flow control on.private ChannelHandlerContext
Http2StreamChannelBootstrap.findCtx()
protected abstract ChannelHandlerContext
AbstractHttp2StreamChannel.parentContext()
protected ChannelHandlerContext
Http2MultiplexCodec.Http2MultiplexCodecStreamChannel.parentContext()
protected ChannelHandlerContext
Http2MultiplexHandler.Http2MultiplexHandlerStreamChannel.parentContext()
Methods in io.netty.handler.codec.http2 with parameters of type ChannelHandlerContextModifier and TypeMethodDescriptionvoid
Http2ConnectionHandler.bind
(ChannelHandlerContext ctx, SocketAddress localAddress, ChannelPromise promise) void
Http2ConnectionHandler.BaseDecoder.channelActive
(ChannelHandlerContext ctx) void
Http2ConnectionHandler.channelActive
(ChannelHandlerContext ctx) void
Http2ConnectionHandler.PrefaceDecoder.channelActive
(ChannelHandlerContext ctx) void
DefaultHttp2LocalFlowController.channelHandlerContext
(ChannelHandlerContext ctx) void
DefaultHttp2RemoteFlowController.channelHandlerContext
(ChannelHandlerContext ctx) Set theChannelHandlerContext
for which to apply flow control on.void
DelegatingDecompressorFrameListener.ConsumedBytesConverter.channelHandlerContext
(ChannelHandlerContext ctx) void
Http2FlowController.channelHandlerContext
(ChannelHandlerContext ctx) Set theChannelHandlerContext
for which to apply flow control on.void
Http2ConnectionHandler.BaseDecoder.channelInactive
(ChannelHandlerContext ctx) void
Http2ConnectionHandler.channelInactive
(ChannelHandlerContext ctx) void
Http2ConnectionHandler.PrefaceDecoder.channelInactive
(ChannelHandlerContext ctx) final void
Http2MultiplexCodec.channelRead
(ChannelHandlerContext ctx, Object msg) Deprecated.void
Http2MultiplexHandler.channelRead
(ChannelHandlerContext ctx, Object msg) void
InboundHttpToHttp2Adapter.channelRead
(ChannelHandlerContext ctx, Object msg) void
Http2ConnectionHandler.channelReadComplete
(ChannelHandlerContext ctx) final void
Http2MultiplexCodec.channelReadComplete
(ChannelHandlerContext ctx) Deprecated.Notifies any child streams of the read completion.void
Http2MultiplexHandler.channelReadComplete
(ChannelHandlerContext ctx) Notifies any child streams of the read completion.(package private) final void
Http2ConnectionHandler.channelReadComplete0
(ChannelHandlerContext ctx) void
Http2ConnectionHandler.channelWritabilityChanged
(ChannelHandlerContext ctx) final void
Http2MultiplexCodec.channelWritabilityChanged
(ChannelHandlerContext ctx) Deprecated.void
Http2MultiplexHandler.channelWritabilityChanged
(ChannelHandlerContext ctx) void
Http2ConnectionHandler.close
(ChannelHandlerContext ctx, ChannelPromise promise) private void
Http2ConnectionHandler.closeConnectionOnError
(ChannelHandlerContext ctx, ChannelFuture future) void
Http2ConnectionHandler.connect
(ChannelHandlerContext ctx, SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) private static Channel
Http2StreamFrameToHttpObjectCodec.connectionChannel
(ChannelHandlerContext ctx) private static HttpScheme
Http2StreamFrameToHttpObjectCodec.connectionScheme
(ChannelHandlerContext ctx) private static Attribute
<HttpScheme> Http2StreamFrameToHttpObjectCodec.connectionSchemeAttribute
(ChannelHandlerContext ctx) private static ByteBuf
Http2ServerUpgradeCodec.createSettingsFrame
(ChannelHandlerContext ctx, ByteBuf payload) Creates an HTTP2-Settings header with the given payload.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 knowledgeabstract void
Http2ConnectionHandler.BaseDecoder.decode
(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) protected void
Http2ConnectionHandler.decode
(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) void
Http2ConnectionHandler.FrameDecoder.decode
(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) void
Http2ConnectionHandler.PrefaceDecoder.decode
(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) protected void
Http2StreamFrameToHttpObjectCodec.decode
(ChannelHandlerContext ctx, Http2StreamFrame frame, List<Object> out) void
DecoratingHttp2ConnectionDecoder.decodeFrame
(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) void
DefaultHttp2ConnectionDecoder.decodeFrame
(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) void
Http2ConnectionDecoder.decodeFrame
(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) Called by theHttp2ConnectionHandler
to decode the next frame from the input buffer.private Http2Settings
Http2ServerUpgradeCodec.decodeSettings
(ChannelHandlerContext ctx, ByteBuf frame) Decodes the settings frame and returns the settings.private Http2Settings
Http2ServerUpgradeCodec.decodeSettingsHeader
(ChannelHandlerContext ctx, CharSequence settingsHeader) Decodes the settings header and returns aHttp2Settings
object.void
Http2ConnectionHandler.deregister
(ChannelHandlerContext ctx, ChannelPromise promise) void
Http2ConnectionHandler.disconnect
(ChannelHandlerContext ctx, ChannelPromise promise) private void
Http2ConnectionHandler.doGracefulShutdown
(ChannelHandlerContext ctx, ChannelFuture future, ChannelPromise promise) protected void
Http2StreamFrameToHttpObjectCodec.encode
(ChannelHandlerContext ctx, HttpObject obj, List<Object> out) Encode from anHttpObject
to anHttp2StreamFrame
.void
DefaultHttp2ConnectionEncoder.FlowControlledData.error
(ChannelHandlerContext ctx, Throwable cause) void
DefaultHttp2ConnectionEncoder.FlowControlledHeaders.error
(ChannelHandlerContext ctx, Throwable cause) 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) HandlesHttp2Exception
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 eventvoid
Http2ConnectionHandler.flush
(ChannelHandlerContext ctx) protected void
AbstractHttp2StreamChannel.flush0
(ChannelHandlerContext ctx) (package private) final void
Http2MultiplexCodec.flush0
(ChannelHandlerContext ctx) Deprecated.protected void
Http2MultiplexCodec.Http2MultiplexCodecStreamChannel.flush0
(ChannelHandlerContext ctx) private CharSequence
Http2ClientUpgradeCodec.getSettingsHeaderValue
(ChannelHandlerContext ctx) Converts the current settings for the handler to the Base64-encoded representation used in the HTTP2-Settings upgrade header.Http2ConnectionHandler.goAway
(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData, ChannelPromise promise) private ChannelFuture
Http2ConnectionHandler.goAway
(ChannelHandlerContext ctx, Http2Exception cause, ChannelPromise promise) Close the remote endpoint with aGO_AWAY
frame.Http2LifecycleManager.goAway
(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData, ChannelPromise promise) Prevents the peer from creating streams and close the connection iferrorCode
is notHttp2Error.NO_ERROR
.(package private) static void
InboundHttpToHttp2Adapter.handle
(ChannelHandlerContext ctx, Http2Connection connection, Http2FrameListener listener, FullHttpMessage message) private ChannelPromise
Http2ControlFrameLimitEncoder.handleOutstandingControlFrames
(ChannelHandlerContext ctx, ChannelPromise promise) void
CleartextHttp2ServerUpgradeHandler.handlerAdded
(ChannelHandlerContext ctx) final void
Http2ChannelDuplexHandler.handlerAdded
(ChannelHandlerContext ctx) void
Http2ConnectionHandler.handlerAdded
(ChannelHandlerContext ctx) final void
Http2FrameCodec.handlerAdded
(ChannelHandlerContext ctx) void
Http2StreamFrameToHttpObjectCodec.handlerAdded
(ChannelHandlerContext ctx) protected void
Http2ChannelDuplexHandler.handlerAdded0
(ChannelHandlerContext ctx) (package private) void
Http2FrameCodec.handlerAdded0
(ChannelHandlerContext ctx) final void
Http2MultiplexCodec.handlerAdded0
(ChannelHandlerContext ctx) Deprecated.protected void
Http2MultiplexHandler.handlerAdded0
(ChannelHandlerContext ctx) final void
Http2ChannelDuplexHandler.handlerRemoved
(ChannelHandlerContext ctx) void
Http2ConnectionHandler.BaseDecoder.handlerRemoved
(ChannelHandlerContext ctx) void
Http2ConnectionHandler.PrefaceDecoder.handlerRemoved
(ChannelHandlerContext ctx) Releases theclientPrefaceString
.protected void
Http2ChannelDuplexHandler.handlerRemoved0
(ChannelHandlerContext ctx) protected void
Http2ConnectionHandler.handlerRemoved0
(ChannelHandlerContext ctx) final void
Http2MultiplexCodec.handlerRemoved0
(ChannelHandlerContext ctx) Deprecated.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.private void
DelegatingDecompressorFrameListener.initDecompressor
(ChannelHandlerContext ctx, int streamId, Http2Headers headers, boolean endOfStream) Checks if a new decompressor object is needed for the stream identified bystreamId
.private boolean
Http2FrameCodec.initializeNewStream
(ChannelHandlerContext ctx, Http2FrameCodec.DefaultHttp2FrameStream http2FrameStream, ChannelPromise promise) boolean
Http2PromisedRequestVerifier.isAuthoritative
(ChannelHandlerContext ctx, Http2Headers headers) Determine if aHttp2Headers
are authoritative for a particularChannelHandlerContext
.private static boolean
Http2MultiplexHandler.isServer
(ChannelHandlerContext ctx) 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
DefaultHttp2ConnectionEncoder.FlowControlledData.merge
(ChannelHandlerContext ctx, Http2RemoteFlowController.FlowControlled next) boolean
DefaultHttp2ConnectionEncoder.FlowControlledHeaders.merge
(ChannelHandlerContext ctx, Http2RemoteFlowController.FlowControlled next) boolean
Http2RemoteFlowController.FlowControlled.merge
(ChannelHandlerContext ctx, Http2RemoteFlowController.FlowControlled next) Merge the contents of thenext
message into this message so they can be written out as one unit.private ChannelFutureListener
Http2ConnectionHandler.newClosingChannelFutureListener
(ChannelHandlerContext ctx, ChannelPromise promise) private EmbeddedChannel
CompressorHttp2ConnectionEncoder.newCompressionChannel
(ChannelHandlerContext ctx, ZlibWrapper wrapper) Generate a new instance of anEmbeddedChannel
capable of compressing dataprivate EmbeddedChannel
CompressorHttp2ConnectionEncoder.newCompressor
(ChannelHandlerContext ctx, Http2Headers headers, boolean endOfStream) Checks if a new compressor object is needed for the stream identified bystreamId
.protected EmbeddedChannel
CompressorHttp2ConnectionEncoder.newContentCompressor
(ChannelHandlerContext ctx, CharSequence contentEncoding) Returns a newEmbeddedChannel
that encodes the HTTP2 message content encoded in the specifiedcontentEncoding
.protected EmbeddedChannel
DelegatingDecompressorFrameListener.newContentDecompressor
(ChannelHandlerContext ctx, CharSequence contentEncoding) Returns a newEmbeddedChannel
that decodes the HTTP2 message content encoded in the specifiedcontentEncoding
.private void
DefaultHttp2ConnectionEncoder.notifyLifecycleManagerOnError
(ChannelFuture future, ChannelHandlerContext ctx) 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
DefaultHttp2ConnectionDecoder.FrameReadListener.onDataRead
(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endOfStream) int
DefaultHttp2ConnectionDecoder.PrefaceFrameListener.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
Http2EmptyDataFrameListener.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
Http2FrameAdapter.onDataRead
(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endOfStream) int
Http2FrameCodec.FrameListener.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 inboundDATA
frame.int
Http2FrameListenerDecorator.onDataRead
(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endOfStream) int
InboundHttp2ToHttpAdapter.onDataRead
(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endOfStream) 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
DefaultHttp2ConnectionDecoder.FrameReadListener.onGoAwayRead
(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData) void
DefaultHttp2ConnectionDecoder.PrefaceFrameListener.onGoAwayRead
(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData) void
Http2EventAdapter.onGoAwayRead
(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData) void
Http2FrameAdapter.onGoAwayRead
(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData) void
Http2FrameCodec.FrameListener.onGoAwayRead
(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData) void
Http2FrameListener.onGoAwayRead
(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData) Handles an inboundGO_AWAY
frame.void
Http2FrameListenerDecorator.onGoAwayRead
(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData) (package private) void
DefaultHttp2ConnectionDecoder.onGoAwayRead0
(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData) void
DefaultHttp2ConnectionDecoder.FrameReadListener.onHeadersRead
(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endOfStream) void
DefaultHttp2ConnectionDecoder.FrameReadListener.onHeadersRead
(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endOfStream) void
DefaultHttp2ConnectionDecoder.PrefaceFrameListener.onHeadersRead
(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endOfStream) void
DefaultHttp2ConnectionDecoder.PrefaceFrameListener.onHeadersRead
(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endOfStream) void
DelegatingDecompressorFrameListener.onHeadersRead
(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream) void
DelegatingDecompressorFrameListener.onHeadersRead
(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endStream) void
Http2EmptyDataFrameListener.onHeadersRead
(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream) void
Http2EmptyDataFrameListener.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 padding, boolean endStream) void
Http2EventAdapter.onHeadersRead
(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endStream) void
Http2FrameAdapter.onHeadersRead
(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream) void
Http2FrameAdapter.onHeadersRead
(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endStream) void
Http2FrameCodec.FrameListener.onHeadersRead
(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endOfStream) void
Http2FrameCodec.FrameListener.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 padding, boolean endOfStream) Handles an inboundHEADERS
frame.void
Http2FrameListener.onHeadersRead
(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endOfStream) Handles an inboundHEADERS
frame with priority information specified.void
Http2FrameListenerDecorator.onHeadersRead
(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream) void
Http2FrameListenerDecorator.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 padding, boolean endOfStream) void
InboundHttp2ToHttpAdapter.onHeadersRead
(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endOfStream) (package private) void
Http2FrameCodec.onHttp2Frame
(ChannelHandlerContext ctx, Http2Frame frame) (package private) final void
Http2MultiplexCodec.onHttp2Frame
(ChannelHandlerContext ctx, Http2Frame frame) Deprecated.(package private) void
Http2FrameCodec.onHttp2FrameStreamException
(ChannelHandlerContext ctx, Http2FrameStreamException cause) (package private) final void
Http2MultiplexCodec.onHttp2FrameStreamException
(ChannelHandlerContext ctx, Http2FrameStreamException cause) Deprecated.private void
Http2MultiplexCodec.onHttp2GoAwayFrame
(ChannelHandlerContext ctx, Http2GoAwayFrame goAwayFrame) Deprecated.private void
Http2MultiplexHandler.onHttp2GoAwayFrame
(ChannelHandlerContext ctx, Http2GoAwayFrame goAwayFrame) (package private) void
Http2FrameCodec.onHttp2StreamStateChanged
(ChannelHandlerContext ctx, Http2FrameCodec.DefaultHttp2FrameStream stream) (package private) final void
Http2MultiplexCodec.onHttp2StreamStateChanged
(ChannelHandlerContext ctx, Http2FrameCodec.DefaultHttp2FrameStream stream) Deprecated.private void
Http2FrameCodec.onHttp2StreamWritabilityChanged
(ChannelHandlerContext ctx, Http2FrameCodec.DefaultHttp2FrameStream stream, boolean writable) private static void
Http2FrameCodec.onHttp2UnknownStreamError
(ChannelHandlerContext ctx, Throwable cause, Http2Exception.StreamException streamException) void
DefaultHttp2ConnectionDecoder.FrameReadListener.onPingAckRead
(ChannelHandlerContext ctx, long data) void
DefaultHttp2ConnectionDecoder.PrefaceFrameListener.onPingAckRead
(ChannelHandlerContext ctx, long data) void
Http2EventAdapter.onPingAckRead
(ChannelHandlerContext ctx, long data) void
Http2FrameAdapter.onPingAckRead
(ChannelHandlerContext ctx, long data) void
Http2FrameCodec.FrameListener.onPingAckRead
(ChannelHandlerContext ctx, long data) void
Http2FrameListener.onPingAckRead
(ChannelHandlerContext ctx, long data) Handles an inboundPING
acknowledgment.void
Http2FrameListenerDecorator.onPingAckRead
(ChannelHandlerContext ctx, long data) void
DefaultHttp2ConnectionDecoder.FrameReadListener.onPingRead
(ChannelHandlerContext ctx, long data) void
DefaultHttp2ConnectionDecoder.PrefaceFrameListener.onPingRead
(ChannelHandlerContext ctx, long data) void
Http2EventAdapter.onPingRead
(ChannelHandlerContext ctx, long data) void
Http2FrameAdapter.onPingRead
(ChannelHandlerContext ctx, long data) void
Http2FrameCodec.FrameListener.onPingRead
(ChannelHandlerContext ctx, long data) void
Http2FrameListener.onPingRead
(ChannelHandlerContext ctx, long data) Handles an inboundPING
frame.void
Http2FrameListenerDecorator.onPingRead
(ChannelHandlerContext ctx, long data) void
DefaultHttp2ConnectionDecoder.FrameReadListener.onPriorityRead
(ChannelHandlerContext ctx, int streamId, int streamDependency, short weight, boolean exclusive) void
DefaultHttp2ConnectionDecoder.PrefaceFrameListener.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
Http2FrameAdapter.onPriorityRead
(ChannelHandlerContext ctx, int streamId, int streamDependency, short weight, boolean exclusive) void
Http2FrameCodec.FrameListener.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 inboundPRIORITY
frame.void
Http2FrameListenerDecorator.onPriorityRead
(ChannelHandlerContext ctx, int streamId, int streamDependency, short weight, boolean exclusive) void
DefaultHttp2ConnectionDecoder.FrameReadListener.onPushPromiseRead
(ChannelHandlerContext ctx, int streamId, int promisedStreamId, Http2Headers headers, int padding) void
DefaultHttp2ConnectionDecoder.PrefaceFrameListener.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
Http2FrameAdapter.onPushPromiseRead
(ChannelHandlerContext ctx, int streamId, int promisedStreamId, Http2Headers headers, int padding) void
Http2FrameCodec.FrameListener.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 inboundPUSH_PROMISE
frame.void
Http2FrameListenerDecorator.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
DefaultHttp2ConnectionDecoder.FrameReadListener.onRstStreamRead
(ChannelHandlerContext ctx, int streamId, long errorCode) void
DefaultHttp2ConnectionDecoder.PrefaceFrameListener.onRstStreamRead
(ChannelHandlerContext ctx, int streamId, long errorCode) void
Http2EventAdapter.onRstStreamRead
(ChannelHandlerContext ctx, int streamId, long errorCode) void
Http2FrameAdapter.onRstStreamRead
(ChannelHandlerContext ctx, int streamId, long errorCode) void
Http2FrameCodec.FrameListener.onRstStreamRead
(ChannelHandlerContext ctx, int streamId, long errorCode) void
Http2FrameListener.onRstStreamRead
(ChannelHandlerContext ctx, int streamId, long errorCode) Handles an inboundRST_STREAM
frame.void
Http2FrameListenerDecorator.onRstStreamRead
(ChannelHandlerContext ctx, int streamId, long errorCode) void
Http2MaxRstFrameListener.onRstStreamRead
(ChannelHandlerContext ctx, int streamId, long errorCode) void
InboundHttp2ToHttpAdapter.onRstStreamRead
(ChannelHandlerContext ctx, int streamId, long errorCode) void
DefaultHttp2ConnectionDecoder.FrameReadListener.onSettingsAckRead
(ChannelHandlerContext ctx) void
DefaultHttp2ConnectionDecoder.PrefaceFrameListener.onSettingsAckRead
(ChannelHandlerContext ctx) void
Http2EventAdapter.onSettingsAckRead
(ChannelHandlerContext ctx) void
Http2FrameAdapter.onSettingsAckRead
(ChannelHandlerContext ctx) void
Http2FrameCodec.FrameListener.onSettingsAckRead
(ChannelHandlerContext ctx) void
Http2FrameListener.onSettingsAckRead
(ChannelHandlerContext ctx) Handles an inboundSETTINGS
acknowledgment frame.void
Http2FrameListenerDecorator.onSettingsAckRead
(ChannelHandlerContext ctx) void
DefaultHttp2ConnectionDecoder.FrameReadListener.onSettingsRead
(ChannelHandlerContext ctx, Http2Settings settings) void
DefaultHttp2ConnectionDecoder.PrefaceFrameListener.onSettingsRead
(ChannelHandlerContext ctx, Http2Settings settings) void
Http2EventAdapter.onSettingsRead
(ChannelHandlerContext ctx, Http2Settings settings) void
Http2FrameAdapter.onSettingsRead
(ChannelHandlerContext ctx, Http2Settings settings) void
Http2FrameCodec.FrameListener.onSettingsRead
(ChannelHandlerContext ctx, Http2Settings settings) void
Http2FrameListener.onSettingsRead
(ChannelHandlerContext ctx, Http2Settings settings) Handles an inboundSETTINGS
frame.void
Http2FrameListenerDecorator.onSettingsRead
(ChannelHandlerContext ctx, Http2Settings settings) void
InboundHttp2ToHttpAdapter.onSettingsRead
(ChannelHandlerContext ctx, Http2Settings settings) protected void
Http2ConnectionHandler.onStreamError
(ChannelHandlerContext ctx, boolean outbound, Throwable cause, Http2Exception.StreamException http2Ex) Handler for a stream error.protected final void
Http2FrameCodec.onStreamError
(ChannelHandlerContext ctx, boolean outbound, Throwable cause, Http2Exception.StreamException streamException) Exceptions for unknown streams, that is streams that have noHttp2FrameStream
object attached are simply logged and replied to by sending a RST_STREAM frame.void
DefaultHttp2ConnectionDecoder.FrameReadListener.onUnknownFrame
(ChannelHandlerContext ctx, byte frameType, int streamId, Http2Flags flags, ByteBuf payload) void
DefaultHttp2ConnectionDecoder.PrefaceFrameListener.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
Http2FrameAdapter.onUnknownFrame
(ChannelHandlerContext ctx, byte frameType, int streamId, Http2Flags flags, ByteBuf payload) void
Http2FrameCodec.FrameListener.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
Http2FrameListenerDecorator.onUnknownFrame
(ChannelHandlerContext ctx, byte frameType, int streamId, Http2Flags flags, ByteBuf payload) (package private) void
DefaultHttp2ConnectionDecoder.onUnknownFrame0
(ChannelHandlerContext ctx, byte frameType, int streamId, Http2Flags flags, ByteBuf payload) private void
Http2FrameCodec.onUpgradeEvent
(ChannelHandlerContext ctx, HttpServerUpgradeHandler.UpgradeEvent evt) (package private) void
Http2FrameCodec.onUserEventTriggered
(ChannelHandlerContext ctx, Object evt) (package private) final void
Http2MultiplexCodec.onUserEventTriggered
(ChannelHandlerContext ctx, Object evt) Deprecated.void
DefaultHttp2ConnectionDecoder.FrameReadListener.onWindowUpdateRead
(ChannelHandlerContext ctx, int streamId, int windowSizeIncrement) void
DefaultHttp2ConnectionDecoder.PrefaceFrameListener.onWindowUpdateRead
(ChannelHandlerContext ctx, int streamId, int windowSizeIncrement) void
Http2EventAdapter.onWindowUpdateRead
(ChannelHandlerContext ctx, int streamId, int windowSizeIncrement) void
Http2FrameAdapter.onWindowUpdateRead
(ChannelHandlerContext ctx, int streamId, int windowSizeIncrement) void
Http2FrameCodec.FrameListener.onWindowUpdateRead
(ChannelHandlerContext ctx, int streamId, int windowSizeIncrement) void
Http2FrameListener.onWindowUpdateRead
(ChannelHandlerContext ctx, int streamId, int windowSizeIncrement) Handles an inboundWINDOW_UPDATE
frame.void
Http2FrameListenerDecorator.onWindowUpdateRead
(ChannelHandlerContext ctx, int streamId, int windowSizeIncrement) void
Http2StreamChannelBootstrap.open0
(ChannelHandlerContext ctx, Promise<Http2StreamChannel> promise) Deprecated.should not be used directly.boolean
Http2ServerUpgradeCodec.prepareUpgradeResponse
(ChannelHandlerContext ctx, FullHttpRequest upgradeRequest, HttpHeaders headers) private static void
Http2ConnectionHandler.processGoAwayWriteResult
(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData, ChannelFuture future) 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.private void
InboundHttp2ToHttpAdapter.processHeadersEnd
(ChannelHandlerContext ctx, Http2Stream stream, FullHttpMessage msg, boolean endOfStream) After HTTP/2 headers have been processed byInboundHttp2ToHttpAdapter.processHeadersBegin(io.netty.channel.ChannelHandlerContext, io.netty.handler.codec.http2.Http2Stream, io.netty.handler.codec.http2.Http2Headers, boolean, boolean, boolean)
this method either sends the result up the pipeline or retains the message for future processing.private void
DefaultHttp2FrameReader.processPayloadState
(ChannelHandlerContext ctx, ByteBuf in, Http2FrameListener listener) private void
Http2ConnectionHandler.processRstStreamWriteResult
(ChannelHandlerContext ctx, Http2Stream stream, ChannelFuture future) void
Http2ConnectionHandler.read
(ChannelHandlerContext ctx) Http2DataChunkedInput.readChunk
(ChannelHandlerContext ctx) Deprecated.private void
DefaultHttp2FrameReader.readDataFrame
(ChannelHandlerContext ctx, ByteBuf payload, Http2FrameListener listener) void
DefaultHttp2FrameReader.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
Http2InboundFrameLogger.readFrame
(ChannelHandlerContext ctx, ByteBuf input, Http2FrameListener listener) private void
DefaultHttp2FrameReader.readGoAwayFrame
(ChannelHandlerContext ctx, ByteBuf payload, Http2FrameListener listener) private void
DefaultHttp2FrameReader.readHeadersFrame
(ChannelHandlerContext ctx, ByteBuf payload, Http2FrameListener listener) private void
DefaultHttp2FrameReader.readPingFrame
(ChannelHandlerContext ctx, long data, Http2FrameListener listener) private void
DefaultHttp2FrameReader.readPriorityFrame
(ChannelHandlerContext ctx, ByteBuf payload, Http2FrameListener listener) private void
DefaultHttp2FrameReader.readPushPromiseFrame
(ChannelHandlerContext ctx, ByteBuf payload, Http2FrameListener listener) private void
DefaultHttp2FrameReader.readRstStreamFrame
(ChannelHandlerContext ctx, ByteBuf payload, Http2FrameListener listener) private void
DefaultHttp2FrameReader.readSettingsFrame
(ChannelHandlerContext ctx, ByteBuf payload, Http2FrameListener listener) private void
DefaultHttp2FrameReader.readUnknownFrame
(ChannelHandlerContext ctx, ByteBuf payload, Http2FrameListener listener) private void
DefaultHttp2FrameReader.readWindowUpdateFrame
(ChannelHandlerContext ctx, ByteBuf payload, Http2FrameListener listener) private static Http2FrameCodec
Http2ChannelDuplexHandler.requireHttp2FrameCodec
(ChannelHandlerContext ctx) Http2ConnectionHandler.resetStream
(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise) private ChannelFuture
Http2ConnectionHandler.resetStream
(ChannelHandlerContext ctx, Http2Stream stream, long errorCode, ChannelPromise promise) Http2LifecycleManager.resetStream
(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise) Ensure the stream identified bystreamId
is reset.private ChannelFuture
Http2ConnectionHandler.resetUnknownStream
(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise) Sends aRST_STREAM
frame even if we don't know about the stream.(package private) void
StreamBufferingEncoder.DataFrame.send
(ChannelHandlerContext ctx, int streamId) (package private) abstract void
StreamBufferingEncoder.Frame.send
(ChannelHandlerContext ctx, int streamId) (package private) void
StreamBufferingEncoder.HeadersFrame.send
(ChannelHandlerContext ctx, int streamId) private static ChannelFuture
DefaultHttp2ConnectionEncoder.sendHeaders
(Http2FrameWriter frameWriter, ChannelHandlerContext ctx, int streamId, Http2Headers headers, boolean hasPriority, int streamDependency, short weight, boolean exclusive, int padding, boolean endOfStream, ChannelPromise promise) Write headers viaHttp2FrameWriter
.private void
Http2ConnectionHandler.PrefaceDecoder.sendPreface
(ChannelHandlerContext ctx) Sends the HTTP/2 connection preface upon establishment of the connection, if not already sent.Http2ClientUpgradeCodec.setUpgradeHeaders
(ChannelHandlerContext ctx, HttpRequest upgradeRequest) private boolean
DefaultHttp2ConnectionDecoder.FrameReadListener.shouldIgnoreHeadersOrDataFrame
(ChannelHandlerContext ctx, int streamId, Http2Stream stream, boolean endOfStream, String frameName) Helper method to determine if a frame that has the semantics of headers or data should be ignored for thestream
(which may benull
) associated withstreamId
.static ByteBuf
Http2CodecUtil.toByteBuf
(ChannelHandlerContext ctx, Throwable cause) Creates a buffer containing the error message from the given exception.private Http2Headers
Http2StreamFrameToHttpObjectCodec.toHttp2Headers
(ChannelHandlerContext ctx, HttpMessage msg) void
Http2ClientUpgradeCodec.upgradeTo
(ChannelHandlerContext ctx, FullHttpResponse upgradeResponse) void
Http2ServerUpgradeCodec.upgradeTo
(ChannelHandlerContext ctx, FullHttpRequest upgradeRequest) final void
Http2FrameCodec.userEventTriggered
(ChannelHandlerContext ctx, Object evt) Handles the cleartext HTTP upgrade event.void
Http2MultiplexHandler.userEventTriggered
(ChannelHandlerContext ctx, Object evt) void
DefaultHttp2ConnectionEncoder.FlowControlledData.write
(ChannelHandlerContext ctx, int allowedBytes) void
DefaultHttp2ConnectionEncoder.FlowControlledHeaders.write
(ChannelHandlerContext ctx, int allowedBytes) void
Http2ConnectionHandler.write
(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) void
Http2FrameCodec.write
(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) Processes allHttp2Frame
s.void
Http2RemoteFlowController.FlowControlled.write
(ChannelHandlerContext ctx, int allowedBytes) Writes up toallowedBytes
of the encapsulated payload to the stream.void
HttpToHttp2ConnectionHandler.write
(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) Handles conversion ofHttpMessage
andHttpContent
to HTTP/2 frames.protected ChannelFuture
AbstractHttp2StreamChannel.write0
(ChannelHandlerContext ctx, Object msg) protected ChannelFuture
Http2MultiplexCodec.Http2MultiplexCodecStreamChannel.write0
(ChannelHandlerContext ctx, Object msg) private ChannelFuture
DefaultHttp2FrameWriter.writeContinuationFrames
(ChannelHandlerContext ctx, int streamId, ByteBuf headerBlock, Http2CodecUtil.SimpleChannelPromiseAggregator promiseAggregator) Writes as many continuation frames as needed untilpadding
andheaderBlock
are consumed.CompressorHttp2ConnectionEncoder.writeData
(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endOfStream, ChannelPromise promise) DecoratingHttp2FrameWriter.writeData
(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endStream, ChannelPromise promise) DefaultHttp2ConnectionEncoder.writeData
(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endOfStream, ChannelPromise promise) DefaultHttp2FrameWriter.writeData
(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endStream, ChannelPromise promise) Http2DataWriter.writeData
(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endStream, ChannelPromise promise) Writes aDATA
frame to the remote endpoint.Http2OutboundFrameLogger.writeData
(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endStream, ChannelPromise promise) StreamBufferingEncoder.writeData
(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endOfStream, ChannelPromise promise) DecoratingHttp2FrameWriter.writeFrame
(ChannelHandlerContext ctx, byte frameType, int streamId, Http2Flags flags, ByteBuf payload, ChannelPromise promise) DefaultHttp2ConnectionEncoder.writeFrame
(ChannelHandlerContext ctx, byte frameType, int streamId, Http2Flags flags, ByteBuf payload, ChannelPromise promise) DefaultHttp2FrameWriter.writeFrame
(ChannelHandlerContext ctx, byte frameType, int streamId, Http2Flags flags, ByteBuf payload, ChannelPromise promise) Http2ConnectionEncoder.writeFrame
(ChannelHandlerContext ctx, byte frameType, int streamId, Http2Flags flags, ByteBuf payload, ChannelPromise promise) Writes the given data to the internalHttp2FrameWriter
without performing any state checks on the connection/stream.Http2FrameWriter.writeFrame
(ChannelHandlerContext ctx, byte frameType, int streamId, Http2Flags flags, ByteBuf payload, ChannelPromise promise) Generic write method for any HTTP/2 frame.Http2OutboundFrameLogger.writeFrame
(ChannelHandlerContext ctx, byte frameType, int streamId, Http2Flags flags, ByteBuf payload, ChannelPromise promise) DecoratingHttp2FrameWriter.writeGoAway
(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData, ChannelPromise promise) DefaultHttp2ConnectionEncoder.writeGoAway
(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData, ChannelPromise promise) DefaultHttp2FrameWriter.writeGoAway
(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData, ChannelPromise promise) Http2FrameWriter.writeGoAway
(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData, ChannelPromise promise) Writes a GO_AWAY frame to the remote endpoint.Http2OutboundFrameLogger.writeGoAway
(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData, ChannelPromise promise) private void
Http2FrameCodec.writeGoAwayFrame
(ChannelHandlerContext ctx, Http2GoAwayFrame frame, ChannelPromise promise) CompressorHttp2ConnectionEncoder.writeHeaders
(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream, ChannelPromise promise) CompressorHttp2ConnectionEncoder.writeHeaders
(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endOfStream, ChannelPromise promise) DecoratingHttp2FrameWriter.writeHeaders
(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream, ChannelPromise promise) DecoratingHttp2FrameWriter.writeHeaders
(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endStream, ChannelPromise promise) DefaultHttp2ConnectionEncoder.writeHeaders
(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream, ChannelPromise promise) DefaultHttp2ConnectionEncoder.writeHeaders
(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endOfStream, ChannelPromise promise) DefaultHttp2FrameWriter.writeHeaders
(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream, ChannelPromise promise) DefaultHttp2FrameWriter.writeHeaders
(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endStream, ChannelPromise promise) Http2FrameWriter.writeHeaders
(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream, ChannelPromise promise) Writes a HEADERS frame to the remote endpoint.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.Http2OutboundFrameLogger.writeHeaders
(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream, ChannelPromise promise) Http2OutboundFrameLogger.writeHeaders
(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endStream, ChannelPromise promise) private static void
HttpToHttp2ConnectionHandler.writeHeaders
(ChannelHandlerContext ctx, Http2ConnectionEncoder encoder, int streamId, HttpHeaders headers, Http2Headers http2Headers, boolean endStream, Http2CodecUtil.SimpleChannelPromiseAggregator promiseAggregator) StreamBufferingEncoder.writeHeaders
(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream, ChannelPromise promise) StreamBufferingEncoder.writeHeaders
(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endOfStream, ChannelPromise promise) private ChannelFuture
DefaultHttp2ConnectionEncoder.writeHeaders0
(ChannelHandlerContext ctx, int streamId, Http2Headers headers, boolean hasPriority, int streamDependency, short weight, boolean exclusive, int padding, boolean endOfStream, ChannelPromise promise) private ChannelFuture
StreamBufferingEncoder.writeHeaders0
(ChannelHandlerContext ctx, int streamId, Http2Headers headers, boolean hasPriority, int streamDependency, short weight, boolean exclusive, int padding, boolean endOfStream, ChannelPromise promise) private void
Http2FrameCodec.writeHeadersFrame
(ChannelHandlerContext ctx, Http2HeadersFrame headersFrame, ChannelPromise promise) private ChannelFuture
DefaultHttp2FrameWriter.writeHeadersInternal
(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream, boolean hasPriority, int streamDependency, short weight, boolean exclusive, ChannelPromise promise) DecoratingHttp2FrameWriter.writePing
(ChannelHandlerContext ctx, boolean ack, long data, ChannelPromise promise) DefaultHttp2ConnectionEncoder.writePing
(ChannelHandlerContext ctx, boolean ack, long data, ChannelPromise promise) DefaultHttp2FrameWriter.writePing
(ChannelHandlerContext ctx, boolean ack, long data, ChannelPromise promise) Http2ControlFrameLimitEncoder.writePing
(ChannelHandlerContext ctx, boolean ack, long data, ChannelPromise promise) Http2FrameWriter.writePing
(ChannelHandlerContext ctx, boolean ack, long data, ChannelPromise promise) Writes a PING frame to the remote endpoint.Http2OutboundFrameLogger.writePing
(ChannelHandlerContext ctx, boolean ack, long data, ChannelPromise promise) DecoratingHttp2FrameWriter.writePriority
(ChannelHandlerContext ctx, int streamId, int streamDependency, short weight, boolean exclusive, ChannelPromise promise) DefaultHttp2ConnectionEncoder.writePriority
(ChannelHandlerContext ctx, int streamId, int streamDependency, short weight, boolean exclusive, ChannelPromise promise) DefaultHttp2FrameWriter.writePriority
(ChannelHandlerContext ctx, int streamId, int streamDependency, short weight, boolean exclusive, ChannelPromise promise) Http2FrameWriter.writePriority
(ChannelHandlerContext ctx, int streamId, int streamDependency, short weight, boolean exclusive, ChannelPromise promise) Writes a PRIORITY frame to the remote endpoint.Http2OutboundFrameLogger.writePriority
(ChannelHandlerContext ctx, int streamId, int streamDependency, short weight, boolean exclusive, ChannelPromise promise) DecoratingHttp2FrameWriter.writePushPromise
(ChannelHandlerContext ctx, int streamId, int promisedStreamId, Http2Headers headers, int padding, ChannelPromise promise) DefaultHttp2ConnectionEncoder.writePushPromise
(ChannelHandlerContext ctx, int streamId, int promisedStreamId, Http2Headers headers, int padding, ChannelPromise promise) DefaultHttp2FrameWriter.writePushPromise
(ChannelHandlerContext ctx, int streamId, int promisedStreamId, Http2Headers headers, int padding, ChannelPromise promise) private void
Http2FrameCodec.writePushPromise
(ChannelHandlerContext ctx, Http2PushPromiseFrame pushPromiseFrame, ChannelPromise promise) Http2FrameWriter.writePushPromise
(ChannelHandlerContext ctx, int streamId, int promisedStreamId, Http2Headers headers, int padding, ChannelPromise promise) Writes a PUSH_PROMISE frame to the remote endpoint.Http2OutboundFrameLogger.writePushPromise
(ChannelHandlerContext ctx, int streamId, int promisedStreamId, Http2Headers headers, int padding, ChannelPromise promise) DecoratingHttp2FrameWriter.writeRstStream
(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise) DefaultHttp2ConnectionEncoder.writeRstStream
(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise) DefaultHttp2FrameWriter.writeRstStream
(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise) Http2ControlFrameLimitEncoder.writeRstStream
(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise) Http2FrameWriter.writeRstStream
(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise) Writes a RST_STREAM frame to the remote endpoint.Http2OutboundFrameLogger.writeRstStream
(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise) StreamBufferingEncoder.writeRstStream
(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise) DecoratingHttp2FrameWriter.writeSettings
(ChannelHandlerContext ctx, Http2Settings settings, ChannelPromise promise) DefaultHttp2ConnectionEncoder.writeSettings
(ChannelHandlerContext ctx, Http2Settings settings, ChannelPromise promise) DefaultHttp2FrameWriter.writeSettings
(ChannelHandlerContext ctx, Http2Settings settings, ChannelPromise promise) Http2FrameWriter.writeSettings
(ChannelHandlerContext ctx, Http2Settings settings, ChannelPromise promise) Writes a SETTINGS frame to the remote endpoint.Http2OutboundFrameLogger.writeSettings
(ChannelHandlerContext ctx, Http2Settings settings, ChannelPromise promise) DecoratingHttp2FrameWriter.writeSettingsAck
(ChannelHandlerContext ctx, ChannelPromise promise) DefaultHttp2ConnectionEncoder.writeSettingsAck
(ChannelHandlerContext ctx, ChannelPromise promise) DefaultHttp2FrameWriter.writeSettingsAck
(ChannelHandlerContext ctx, ChannelPromise promise) Http2ControlFrameLimitEncoder.writeSettingsAck
(ChannelHandlerContext ctx, ChannelPromise promise) Http2FrameWriter.writeSettingsAck
(ChannelHandlerContext ctx, ChannelPromise promise) Writes a SETTINGS acknowledgment to the remote endpoint.Http2OutboundFrameLogger.writeSettingsAck
(ChannelHandlerContext ctx, ChannelPromise promise) DecoratingHttp2FrameWriter.writeWindowUpdate
(ChannelHandlerContext ctx, int streamId, int windowSizeIncrement, ChannelPromise promise) DefaultHttp2ConnectionEncoder.writeWindowUpdate
(ChannelHandlerContext ctx, int streamId, int windowSizeIncrement, ChannelPromise promise) DefaultHttp2FrameWriter.writeWindowUpdate
(ChannelHandlerContext ctx, int streamId, int windowSizeIncrement, ChannelPromise promise) Http2FrameWriter.writeWindowUpdate
(ChannelHandlerContext ctx, int streamId, int windowSizeIncrement, ChannelPromise promise) Writes a WINDOW_UPDATE frame to the remote endpoint.Http2OutboundFrameLogger.writeWindowUpdate
(ChannelHandlerContext ctx, int streamId, int windowSizeIncrement, ChannelPromise promise) Constructors in io.netty.handler.codec.http2 with parameters of type ChannelHandlerContextModifierConstructorDescription(package private)
ClosingChannelFutureListener
(ChannelHandlerContext ctx, ChannelPromise promise) (package private)
ClosingChannelFutureListener
(ChannelHandlerContext ctx, ChannelPromise promise, long timeout, TimeUnit unit) (package private)
PendingStream
(ChannelHandlerContext ctx, int streamId) (package private)
-
Uses of ChannelHandlerContext in io.netty.handler.codec.json
Methods in io.netty.handler.codec.json with parameters of type ChannelHandlerContextModifier and TypeMethodDescriptionprotected 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. -
Uses of ChannelHandlerContext in io.netty.handler.codec.memcache
Methods in io.netty.handler.codec.memcache with parameters of type ChannelHandlerContextModifier and TypeMethodDescriptionprotected void
AbstractMemcacheObjectEncoder.encode
(ChannelHandlerContext ctx, Object msg, List<Object> out) protected abstract ByteBuf
AbstractMemcacheObjectEncoder.encodeMessage
(ChannelHandlerContext ctx, M msg) Take the givenMemcacheMessage
and encode it into a writableByteBuf
. -
Uses of ChannelHandlerContext in io.netty.handler.codec.memcache.binary
Methods in io.netty.handler.codec.memcache.binary with parameters of type ChannelHandlerContextModifier and TypeMethodDescriptionvoid
AbstractBinaryMemcacheDecoder.channelInactive
(ChannelHandlerContext ctx) When the channel goes inactive, release all frames to prevent data leaks.void
BinaryMemcacheClientCodec.Decoder.channelInactive
(ChannelHandlerContext ctx) protected void
AbstractBinaryMemcacheDecoder.decode
(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) protected void
BinaryMemcacheClientCodec.Decoder.decode
(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) protected void
BinaryMemcacheClientCodec.Encoder.encode
(ChannelHandlerContext ctx, Object msg, List<Object> out) protected ByteBuf
AbstractBinaryMemcacheEncoder.encodeMessage
(ChannelHandlerContext ctx, M msg) -
Uses of ChannelHandlerContext in io.netty.handler.codec.mqtt
Methods in io.netty.handler.codec.mqtt with parameters of type ChannelHandlerContextModifier and TypeMethodDescriptionprotected void
MqttDecoder.decode
(ChannelHandlerContext ctx, ByteBuf buffer, List<Object> out) private MqttConnAckVariableHeader
MqttDecoder.decodeConnAckVariableHeader
(ChannelHandlerContext ctx, ByteBuf buffer) private MqttConnectVariableHeader
MqttDecoder.decodeConnectionVariableHeader
(ChannelHandlerContext ctx, ByteBuf buffer) private static MqttFixedHeader
MqttDecoder.decodeFixedHeader
(ChannelHandlerContext ctx, ByteBuf buffer) Decodes the fixed header.MqttDecoder.decodeMessageIdAndPropertiesVariableHeader
(ChannelHandlerContext ctx, ByteBuf buffer) private Object
MqttDecoder.decodePayload
(ChannelHandlerContext ctx, ByteBuf buffer, MqttMessageType messageType, int maxClientIdLength, Object variableHeader) Decodes the payload.private MqttPublishVariableHeader
MqttDecoder.decodePublishVariableHeader
(ChannelHandlerContext ctx, ByteBuf buffer, MqttFixedHeader mqttFixedHeader) private MqttUnsubAckPayload
MqttDecoder.decodeUnsubAckPayload
(ChannelHandlerContext ctx, ByteBuf buffer) private Object
MqttDecoder.decodeVariableHeader
(ChannelHandlerContext ctx, ByteBuf buffer, MqttFixedHeader mqttFixedHeader) Decodes the variable header (if any)(package private) static ByteBuf
MqttEncoder.doEncode
(ChannelHandlerContext ctx, MqttMessage message) This is the main encoding method.protected void
MqttEncoder.encode
(ChannelHandlerContext ctx, MqttMessage msg, List<Object> out) private static ByteBuf
MqttEncoder.encodeConnAckMessage
(ChannelHandlerContext ctx, MqttConnAckMessage message) private static ByteBuf
MqttEncoder.encodeConnectMessage
(ChannelHandlerContext ctx, MqttConnectMessage message) private static ByteBuf
MqttEncoder.encodePublishMessage
(ChannelHandlerContext ctx, MqttPublishMessage message) private static ByteBuf
MqttEncoder.encodePubReplyMessage
(ChannelHandlerContext ctx, MqttMessage message) private static ByteBuf
MqttEncoder.encodeReasonCodePlusPropertiesMessage
(ChannelHandlerContext ctx, MqttMessage message) private static ByteBuf
MqttEncoder.encodeSubAckMessage
(ChannelHandlerContext ctx, MqttSubAckMessage message) private static ByteBuf
MqttEncoder.encodeSubscribeMessage
(ChannelHandlerContext ctx, MqttSubscribeMessage message) private static ByteBuf
MqttEncoder.encodeUnsubAckMessage
(ChannelHandlerContext ctx, MqttUnsubAckMessage message) private static ByteBuf
MqttEncoder.encodeUnsubscribeMessage
(ChannelHandlerContext ctx, MqttUnsubscribeMessage message) (package private) static MqttVersion
MqttCodecUtil.getMqttVersion
(ChannelHandlerContext ctx) (package private) static void
MqttCodecUtil.setMqttVersion
(ChannelHandlerContext ctx, MqttVersion version) (package private) static MqttFixedHeader
MqttCodecUtil.validateFixedHeader
(ChannelHandlerContext ctx, MqttFixedHeader mqttFixedHeader) -
Uses of ChannelHandlerContext in io.netty.handler.codec.redis
Methods in io.netty.handler.codec.redis with parameters of type ChannelHandlerContextModifier and TypeMethodDescriptionprotected void
RedisArrayAggregator.decode
(ChannelHandlerContext ctx, RedisMessage msg, List<Object> out) protected void
RedisDecoder.decode
(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) protected void
RedisEncoder.encode
(ChannelHandlerContext ctx, RedisMessage msg, List<Object> out) -
Uses of ChannelHandlerContext in io.netty.handler.codec.sctp
Methods in io.netty.handler.codec.sctp with parameters of type ChannelHandlerContextModifier and TypeMethodDescriptionprotected 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) -
Uses of ChannelHandlerContext in io.netty.handler.codec.serialization
Methods in io.netty.handler.codec.serialization with parameters of type ChannelHandlerContextModifier and TypeMethodDescriptionprotected 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. -
Uses of ChannelHandlerContext in io.netty.handler.codec.smtp
Methods in io.netty.handler.codec.smtp with parameters of type ChannelHandlerContextModifier and TypeMethodDescriptionprotected SmtpResponse
SmtpResponseDecoder.decode
(ChannelHandlerContext ctx, ByteBuf buffer) protected void
SmtpRequestEncoder.encode
(ChannelHandlerContext ctx, Object msg, List<Object> out) -
Uses of ChannelHandlerContext in io.netty.handler.codec.socks
Methods in io.netty.handler.codec.socks with parameters of type ChannelHandlerContextModifier and TypeMethodDescriptionprotected void
SocksAuthRequestDecoder.decode
(ChannelHandlerContext ctx, ByteBuf byteBuf, List<Object> out) protected void
SocksAuthResponseDecoder.decode
(ChannelHandlerContext channelHandlerContext, ByteBuf byteBuf, List<Object> out) protected void
SocksCmdRequestDecoder.decode
(ChannelHandlerContext ctx, ByteBuf byteBuf, List<Object> out) protected void
SocksCmdResponseDecoder.decode
(ChannelHandlerContext ctx, ByteBuf byteBuf, List<Object> out) protected void
SocksInitRequestDecoder.decode
(ChannelHandlerContext ctx, ByteBuf byteBuf, List<Object> out) protected void
SocksInitResponseDecoder.decode
(ChannelHandlerContext ctx, ByteBuf byteBuf, List<Object> out) protected void
SocksMessageEncoder.encode
(ChannelHandlerContext ctx, SocksMessage msg, ByteBuf out) -
Uses of ChannelHandlerContext in io.netty.handler.codec.socksx
Methods in io.netty.handler.codec.socksx with parameters of type ChannelHandlerContextModifier and TypeMethodDescriptionprotected void
SocksPortUnificationServerHandler.decode
(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) private static void
SocksPortUnificationServerHandler.logKnownVersion
(ChannelHandlerContext ctx, SocksVersion version) private static void
SocksPortUnificationServerHandler.logUnknownVersion
(ChannelHandlerContext ctx, byte versionVal) -
Uses of ChannelHandlerContext in io.netty.handler.codec.socksx.v4
Methods in io.netty.handler.codec.socksx.v4 with parameters of type ChannelHandlerContextModifier and TypeMethodDescriptionprotected void
Socks4ClientDecoder.decode
(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) protected void
Socks4ServerDecoder.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) -
Uses of ChannelHandlerContext in io.netty.handler.codec.socksx.v5
Methods in io.netty.handler.codec.socksx.v5 with parameters of type ChannelHandlerContextModifier and TypeMethodDescriptionprotected void
Socks5CommandRequestDecoder.decode
(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) protected void
Socks5CommandResponseDecoder.decode
(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) protected void
Socks5InitialRequestDecoder.decode
(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) protected void
Socks5InitialResponseDecoder.decode
(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) protected void
Socks5PasswordAuthRequestDecoder.decode
(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) protected void
Socks5PasswordAuthResponseDecoder.decode
(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) protected void
Socks5ClientEncoder.encode
(ChannelHandlerContext ctx, Socks5Message msg, ByteBuf out) protected void
Socks5ServerEncoder.encode
(ChannelHandlerContext ctx, Socks5Message msg, ByteBuf out) -
Uses of ChannelHandlerContext in io.netty.handler.codec.spdy
Fields in io.netty.handler.codec.spdy declared as ChannelHandlerContextModifier and TypeFieldDescriptionprivate ChannelHandlerContext
SpdyFrameCodec.ctx
private final ChannelHandlerContext
SpdySessionHandler.ClosingChannelFutureListener.ctx
Methods in io.netty.handler.codec.spdy with parameters of type ChannelHandlerContextModifier and TypeMethodDescriptionvoid
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
SpdyHttpDecoder.decode
(ChannelHandlerContext ctx, SpdyFrame msg, List<Object> out) protected void
SpdyHttpResponseStreamIdHandler.decode
(ChannelHandlerContext ctx, Object msg, List<Object> out) void
SpdyFrameCodec.deregister
(ChannelHandlerContext ctx, ChannelPromise promise) void
SpdyFrameCodec.disconnect
(ChannelHandlerContext ctx, ChannelPromise promise) protected void
SpdyHttpEncoder.encode
(ChannelHandlerContext ctx, HttpObject msg, List<Object> out) protected void
SpdyHttpResponseStreamIdHandler.encode
(ChannelHandlerContext ctx, HttpMessage msg, List<Object> out) void
SpdySessionHandler.exceptionCaught
(ChannelHandlerContext ctx, Throwable cause) void
SpdyFrameCodec.flush
(ChannelHandlerContext ctx) private void
SpdySessionHandler.handleOutboundMessage
(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) void
SpdyFrameCodec.handlerAdded
(ChannelHandlerContext ctx) private void
SpdySessionHandler.issueSessionError
(ChannelHandlerContext ctx, SpdySessionStatus status) private void
SpdySessionHandler.issueStreamError
(ChannelHandlerContext ctx, int streamId, SpdyStreamStatus status) void
SpdyFrameCodec.read
(ChannelHandlerContext ctx) private void
SpdySessionHandler.sendGoAwayFrame
(ChannelHandlerContext ctx, ChannelPromise future) private ChannelFuture
SpdySessionHandler.sendGoAwayFrame
(ChannelHandlerContext ctx, SpdySessionStatus status) private void
SpdySessionHandler.updateSendWindowSize
(ChannelHandlerContext ctx, int streamId, int deltaWindowSize) void
SpdyFrameCodec.write
(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) void
SpdySessionHandler.write
(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) Constructors in io.netty.handler.codec.spdy with parameters of type ChannelHandlerContextModifierConstructorDescription(package private)
ClosingChannelFutureListener
(ChannelHandlerContext ctx, ChannelPromise promise) -
Uses of ChannelHandlerContext in io.netty.handler.codec.stomp
Methods in io.netty.handler.codec.stomp with parameters of type ChannelHandlerContextModifier and TypeMethodDescriptionprotected void
StompSubframeDecoder.decode
(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) protected void
StompSubframeEncoder.encode
(ChannelHandlerContext ctx, StompSubframe msg, List<Object> out) private static ByteBuf
StompSubframeEncoder.encodeContent
(StompContentSubframe content, ChannelHandlerContext ctx) private ByteBuf
StompSubframeEncoder.encodeFullFrame
(StompFrame frame, ChannelHandlerContext ctx) -
Uses of ChannelHandlerContext in io.netty.handler.codec.string
Methods in io.netty.handler.codec.string with parameters of type ChannelHandlerContextModifier and TypeMethodDescriptionprotected 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) -
Uses of ChannelHandlerContext in io.netty.handler.codec.xml
Methods in io.netty.handler.codec.xml with parameters of type ChannelHandlerContextModifier and TypeMethodDescriptionprotected void
XmlDecoder.decode
(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) protected void
XmlFrameDecoder.decode
(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) private static void
XmlFrameDecoder.fail
(ChannelHandlerContext ctx) -
Uses of ChannelHandlerContext in io.netty.handler.flow
Methods in io.netty.handler.flow with parameters of type ChannelHandlerContextModifier and TypeMethodDescriptionvoid
FlowControlHandler.channelInactive
(ChannelHandlerContext ctx) void
FlowControlHandler.channelRead
(ChannelHandlerContext ctx, Object msg) void
FlowControlHandler.channelReadComplete
(ChannelHandlerContext ctx) private int
FlowControlHandler.dequeue
(ChannelHandlerContext ctx, int minConsume) Dequeues one or many (or none) messages depending on the channel's auto reading state and returns the number of messages that were consumed from the internal queue.void
FlowControlHandler.handlerAdded
(ChannelHandlerContext ctx) void
FlowControlHandler.handlerRemoved
(ChannelHandlerContext ctx) void
FlowControlHandler.read
(ChannelHandlerContext ctx) -
Uses of ChannelHandlerContext in io.netty.handler.flush
Fields in io.netty.handler.flush declared as ChannelHandlerContextMethods in io.netty.handler.flush with parameters of type ChannelHandlerContextModifier and TypeMethodDescriptionvoid
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) private void
FlushConsolidationHandler.flushIfNeeded
(ChannelHandlerContext ctx) private void
FlushConsolidationHandler.flushNow
(ChannelHandlerContext ctx) void
FlushConsolidationHandler.handlerAdded
(ChannelHandlerContext ctx) void
FlushConsolidationHandler.handlerRemoved
(ChannelHandlerContext ctx) private void
FlushConsolidationHandler.resetReadAndFlushIfNeeded
(ChannelHandlerContext ctx) private void
FlushConsolidationHandler.scheduleFlush
(ChannelHandlerContext ctx) -
Uses of ChannelHandlerContext in io.netty.handler.ipfilter
Methods in io.netty.handler.ipfilter with parameters of type ChannelHandlerContextModifier and TypeMethodDescriptionprotected abstract boolean
AbstractRemoteAddressFilter.accept
(ChannelHandlerContext ctx, T remoteAddress) This method is called immediately after aChannel
gets registered.protected boolean
IpSubnetFilter.accept
(ChannelHandlerContext ctx, InetSocketAddress remoteAddress) protected boolean
RuleBasedIpFilter.accept
(ChannelHandlerContext ctx, InetSocketAddress remoteAddress) protected boolean
UniqueIpFilter.accept
(ChannelHandlerContext ctx, InetSocketAddress remoteAddress) protected void
AbstractRemoteAddressFilter.channelAccepted
(ChannelHandlerContext ctx, T remoteAddress) This method is called ifremoteAddress
gets accepted byAbstractRemoteAddressFilter.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 ifremoteAddress
gets rejected byAbstractRemoteAddressFilter.accept(ChannelHandlerContext, SocketAddress)
.private boolean
AbstractRemoteAddressFilter.handleNewChannel
(ChannelHandlerContext ctx) -
Uses of ChannelHandlerContext in io.netty.handler.logging
Methods in io.netty.handler.logging with parameters of type ChannelHandlerContextModifier and TypeMethodDescriptionvoid
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.private String
LoggingHandler.formatByteBuf
(ChannelHandlerContext ctx, String eventName, ByteBuf msg) Generates the default log message of the specified event whose argument is aByteBuf
.private String
LoggingHandler.formatByteBufHolder
(ChannelHandlerContext ctx, String eventName, ByteBufHolder msg) Generates the default log message of the specified event whose argument is aByteBufHolder
.private static String
LoggingHandler.formatSimple
(ChannelHandlerContext ctx, String eventName, Object msg) Generates the default log message of the specified event whose argument is an arbitrary object.void
LoggingHandler.userEventTriggered
(ChannelHandlerContext ctx, Object evt) void
LoggingHandler.write
(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) -
Uses of ChannelHandlerContext in io.netty.handler.pcap
Methods in io.netty.handler.pcap with parameters of type ChannelHandlerContextModifier and TypeMethodDescriptionvoid
PcapWriteHandler.channelActive
(ChannelHandlerContext ctx) void
PcapWriteHandler.channelRead
(ChannelHandlerContext ctx, Object msg) private void
PcapWriteHandler.completeTCPWrite
(InetSocketAddress srcAddr, InetSocketAddress dstAddr, ByteBuf tcpBuf, ByteBufAllocator byteBufAllocator, ChannelHandlerContext ctx) Write TCP/IP L3 and L2 here.private void
PcapWriteHandler.completeUDPWrite
(InetSocketAddress srcAddr, InetSocketAddress dstAddr, ByteBuf udpBuf, ByteBufAllocator byteBufAllocator, ChannelHandlerContext ctx) Write UDP/IP L3 and L2 here.void
PcapWriteHandler.exceptionCaught
(ChannelHandlerContext ctx, Throwable cause) void
PcapWriteHandler.handlerRemoved
(ChannelHandlerContext ctx) private void
PcapWriteHandler.handleTCP
(ChannelHandlerContext ctx, Object msg, boolean isWriteOperation) Handle TCP L4private void
PcapWriteHandler.handleTcpPacket
(ChannelHandlerContext ctx, ByteBuf packet, boolean isWriteOperation, ByteBufAllocator byteBufAllocator) private void
PcapWriteHandler.handleUDP
(ChannelHandlerContext ctx, Object msg, boolean isWriteOperation) Handle UDP l4private void
PcapWriteHandler.initializeIfNecessary
(ChannelHandlerContext ctx) void
PcapWriteHandler.write
(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) -
Uses of ChannelHandlerContext in io.netty.handler.proxy
Fields in io.netty.handler.proxy declared as ChannelHandlerContextMethods in io.netty.handler.proxy with parameters of type ChannelHandlerContextModifier and TypeMethodDescriptionprotected void
HttpProxyHandler.addCodec
(ChannelHandlerContext ctx) protected abstract void
ProxyHandler.addCodec
(ChannelHandlerContext ctx) Adds the codec handlers required to communicate with the proxy server.protected void
Socks4ProxyHandler.addCodec
(ChannelHandlerContext ctx) protected void
Socks5ProxyHandler.addCodec
(ChannelHandlerContext ctx) private void
ProxyHandler.addPendingWrite
(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) void
HttpProxyHandler.HttpClientCodecWrapper.bind
(ChannelHandlerContext ctx, SocketAddress localAddress, ChannelPromise promise) void
HttpProxyHandler.HttpClientCodecWrapper.channelActive
(ChannelHandlerContext ctx) final void
ProxyHandler.channelActive
(ChannelHandlerContext ctx) void
HttpProxyHandler.HttpClientCodecWrapper.channelInactive
(ChannelHandlerContext ctx) final void
ProxyHandler.channelInactive
(ChannelHandlerContext ctx) void
HttpProxyHandler.HttpClientCodecWrapper.channelRead
(ChannelHandlerContext ctx, Object msg) final void
ProxyHandler.channelRead
(ChannelHandlerContext ctx, Object msg) void
HttpProxyHandler.HttpClientCodecWrapper.channelReadComplete
(ChannelHandlerContext ctx) final void
ProxyHandler.channelReadComplete
(ChannelHandlerContext ctx) void
HttpProxyHandler.HttpClientCodecWrapper.channelRegistered
(ChannelHandlerContext ctx) void
HttpProxyHandler.HttpClientCodecWrapper.channelUnregistered
(ChannelHandlerContext ctx) void
HttpProxyHandler.HttpClientCodecWrapper.channelWritabilityChanged
(ChannelHandlerContext ctx) void
HttpProxyHandler.HttpClientCodecWrapper.close
(ChannelHandlerContext ctx, ChannelPromise promise) void
HttpProxyHandler.HttpClientCodecWrapper.connect
(ChannelHandlerContext ctx, SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) final void
ProxyHandler.connect
(ChannelHandlerContext ctx, SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) void
HttpProxyHandler.HttpClientCodecWrapper.deregister
(ChannelHandlerContext ctx, ChannelPromise promise) void
HttpProxyHandler.HttpClientCodecWrapper.disconnect
(ChannelHandlerContext ctx, ChannelPromise promise) void
HttpProxyHandler.HttpClientCodecWrapper.exceptionCaught
(ChannelHandlerContext ctx, Throwable cause) final void
ProxyHandler.exceptionCaught
(ChannelHandlerContext ctx, Throwable cause) void
HttpProxyHandler.HttpClientCodecWrapper.flush
(ChannelHandlerContext ctx) final void
ProxyHandler.flush
(ChannelHandlerContext ctx) void
HttpProxyHandler.HttpClientCodecWrapper.handlerAdded
(ChannelHandlerContext ctx) final void
ProxyHandler.handlerAdded
(ChannelHandlerContext ctx) protected boolean
HttpProxyHandler.handleResponse
(ChannelHandlerContext ctx, Object response) protected abstract boolean
ProxyHandler.handleResponse
(ChannelHandlerContext ctx, Object response) Handles the message received from the proxy server.protected boolean
Socks4ProxyHandler.handleResponse
(ChannelHandlerContext ctx, Object response) protected boolean
Socks5ProxyHandler.handleResponse
(ChannelHandlerContext ctx, Object response) void
HttpProxyHandler.HttpClientCodecWrapper.handlerRemoved
(ChannelHandlerContext ctx) protected Object
HttpProxyHandler.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
Socks4ProxyHandler.newInitialMessage
(ChannelHandlerContext ctx) protected Object
Socks5ProxyHandler.newInitialMessage
(ChannelHandlerContext ctx) void
HttpProxyHandler.HttpClientCodecWrapper.read
(ChannelHandlerContext ctx) private static void
ProxyHandler.readIfNeeded
(ChannelHandlerContext ctx) protected void
HttpProxyHandler.removeDecoder
(ChannelHandlerContext ctx) protected abstract void
ProxyHandler.removeDecoder
(ChannelHandlerContext ctx) Removes the decoders added inProxyHandler.addCodec(ChannelHandlerContext)
.protected void
Socks4ProxyHandler.removeDecoder
(ChannelHandlerContext ctx) protected void
Socks5ProxyHandler.removeDecoder
(ChannelHandlerContext ctx) protected void
HttpProxyHandler.removeEncoder
(ChannelHandlerContext ctx) protected abstract void
ProxyHandler.removeEncoder
(ChannelHandlerContext ctx) Removes the encoders added inProxyHandler.addCodec(ChannelHandlerContext)
.protected void
Socks4ProxyHandler.removeEncoder
(ChannelHandlerContext ctx) protected void
Socks5ProxyHandler.removeEncoder
(ChannelHandlerContext ctx) private void
Socks5ProxyHandler.sendConnectCommand
(ChannelHandlerContext ctx) private void
ProxyHandler.sendInitialMessage
(ChannelHandlerContext ctx) Sends the initial message to be sent to the proxy server.void
HttpProxyHandler.HttpClientCodecWrapper.userEventTriggered
(ChannelHandlerContext ctx, Object evt) void
HttpProxyHandler.HttpClientCodecWrapper.write
(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) final void
ProxyHandler.write
(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) -
Uses of ChannelHandlerContext in io.netty.handler.ssl
Fields in io.netty.handler.ssl declared as ChannelHandlerContextModifier and TypeFieldDescriptionprivate ChannelHandlerContext
ApplicationProtocolNegotiationHandler.ctx
private ChannelHandlerContext
SslHandler.ctx
Methods in io.netty.handler.ssl with parameters of type ChannelHandlerContextModifier and TypeMethodDescriptionprivate ByteBuf
SslHandler.allocate
(ChannelHandlerContext ctx, int capacity) Always prefer a direct buffer when it's pooled, so that we reduce the number of memory copies inOpenSslEngine
.private ByteBuf
SslHandler.allocateOutNetBuf
(ChannelHandlerContext ctx, int pendingBytes, int numComponents) Allocates an outbound network buffer forSSLEngine.wrap(ByteBuffer, ByteBuffer)
which can encrypt the specified amount of pending bytes.void
SslClientHelloHandler.bind
(ChannelHandlerContext ctx, SocketAddress localAddress, ChannelPromise promise) void
SslHandler.bind
(ChannelHandlerContext ctx, SocketAddress localAddress, ChannelPromise promise) void
AbstractSniHandler.channelActive
(ChannelHandlerContext ctx) void
SslHandler.channelActive
(ChannelHandlerContext ctx) Issues an initial TLS handshake once connected when used in client-modevoid
ApplicationProtocolNegotiationHandler.channelInactive
(ChannelHandlerContext ctx) void
SslHandler.channelInactive
(ChannelHandlerContext ctx) void
ApplicationProtocolNegotiationHandler.channelRead
(ChannelHandlerContext ctx, Object msg) void
SslHandler.channelReadComplete
(ChannelHandlerContext ctx) private void
SslHandler.channelReadComplete0
(ChannelHandlerContext ctx) private void
AbstractSniHandler.checkStartTimeout
(ChannelHandlerContext ctx) void
SslClientHelloHandler.close
(ChannelHandlerContext ctx, ChannelPromise promise) void
SslHandler.close
(ChannelHandlerContext ctx, ChannelPromise promise) private void
SslHandler.closeOutboundAndChannel
(ChannelHandlerContext ctx, ChannelPromise promise, boolean disconnect) protected abstract void
ApplicationProtocolNegotiationHandler.configurePipeline
(ChannelHandlerContext ctx, String protocol) Invoked on successful initial SSL/TLS handshake.void
SslClientHelloHandler.connect
(ChannelHandlerContext ctx, SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) void
SslHandler.connect
(ChannelHandlerContext ctx, SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) protected void
OptionalSslHandler.decode
(ChannelHandlerContext context, ByteBuf in, List<Object> out) protected void
SslClientHelloHandler.decode
(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) protected void
SslHandler.decode
(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) private void
SslHandler.decodeJdkCompatible
(ChannelHandlerContext ctx, ByteBuf in) private void
SslHandler.decodeNonJdkCompatible
(ChannelHandlerContext ctx, ByteBuf in) void
SslClientHelloHandler.deregister
(ChannelHandlerContext ctx, ChannelPromise promise) void
SslHandler.deregister
(ChannelHandlerContext ctx, ChannelPromise promise) void
SslClientHelloHandler.disconnect
(ChannelHandlerContext ctx, ChannelPromise promise) void
SslHandler.disconnect
(ChannelHandlerContext ctx, ChannelPromise promise) void
ApplicationProtocolNegotiationHandler.exceptionCaught
(ChannelHandlerContext ctx, Throwable cause) void
SslHandler.exceptionCaught
(ChannelHandlerContext ctx, Throwable cause) private void
SslHandler.executeChannelRead
(ChannelHandlerContext ctx, ByteBuf decodedOut) private void
SslHandler.executeNotifyClosePromise
(ChannelHandlerContext ctx) private static void
AbstractSniHandler.fireSniCompletionEvent
(ChannelHandlerContext ctx, String hostname, Future<?> future) void
SslClientHelloHandler.flush
(ChannelHandlerContext ctx) void
SslHandler.flush
(ChannelHandlerContext ctx) private void
SslHandler.flush
(ChannelHandlerContext ctx, ChannelPromise promise) private void
SslHandler.flushIfNeeded
(ChannelHandlerContext ctx) private void
SslHandler.forceFlush
(ChannelHandlerContext ctx) (package private) static void
SslUtils.handleHandshakeFailure
(ChannelHandlerContext ctx, Throwable cause, boolean notify) private void
OptionalSslHandler.handleNonSsl
(ChannelHandlerContext context) void
AbstractSniHandler.handlerAdded
(ChannelHandlerContext ctx) void
ApplicationProtocolNegotiationHandler.handlerAdded
(ChannelHandlerContext ctx) void
SslHandler.handlerAdded
(ChannelHandlerContext ctx) void
ApplicationProtocolNegotiationHandler.handlerRemoved
(ChannelHandlerContext ctx) protected void
SslClientHelloHandler.handlerRemoved0
(ChannelHandlerContext ctx) void
SslHandler.handlerRemoved0
(ChannelHandlerContext ctx) private void
OptionalSslHandler.handleSsl
(ChannelHandlerContext context) private void
SslHandler.handleUnwrapThrowable
(ChannelHandlerContext ctx, Throwable cause) protected void
ApplicationProtocolNegotiationHandler.handshakeFailure
(ChannelHandlerContext ctx, Throwable cause) Invoked on failed initial SSL/TLS handshake.AbstractSniHandler.lookup
(ChannelHandlerContext ctx, ByteBuf clientHello) AbstractSniHandler.lookup
(ChannelHandlerContext ctx, String hostname) Kicks off a lookup for the given SNI value and returns aFuture
which in turn will notify theAbstractSniHandler.onLookupComplete(ChannelHandlerContext, String, Future)
on completion.protected Future
<SslContext> SniHandler.lookup
(ChannelHandlerContext ctx, String hostname) The default implementation will simply callAsyncMapping.map(Object, Promise)
but users can override this method to implement custom behavior.SslClientHelloHandler.lookup
(ChannelHandlerContext ctx, ByteBuf clientHello) Kicks off a lookup for the givenClientHello
and returns aFuture
which in turn will notify theSslClientHelloHandler.onLookupComplete(ChannelHandlerContext, Future)
on completion.protected ChannelHandler
OptionalSslHandler.newNonSslHandler
(ChannelHandlerContext context) Override to configure the ChannelHandler.protected SslHandler
OptionalSslHandler.newSslHandler
(ChannelHandlerContext context, SslContext sslContext) Override to configure the SslHandler eg.protected void
AbstractSniHandler.onLookupComplete
(ChannelHandlerContext ctx, Future<T> future) protected abstract void
AbstractSniHandler.onLookupComplete
(ChannelHandlerContext ctx, String hostname, Future<T> future) Called upon completion of theAbstractSniHandler.lookup(ChannelHandlerContext, String)
Future
.protected final void
SniHandler.onLookupComplete
(ChannelHandlerContext ctx, String hostname, Future<SslContext> future) protected abstract void
SslClientHelloHandler.onLookupComplete
(ChannelHandlerContext ctx, Future<T> future) Called upon completion of theSslClientHelloHandler.lookup(ChannelHandlerContext, ByteBuf)
Future
.void
SslClientHelloHandler.read
(ChannelHandlerContext ctx) void
SslHandler.read
(ChannelHandlerContext ctx) private void
SslHandler.readIfNeeded
(ChannelHandlerContext ctx) private void
SslHandler.releaseAndFailAll
(ChannelHandlerContext ctx, Throwable cause) private void
ApplicationProtocolNegotiationHandler.removeSelfIfPresent
(ChannelHandlerContext ctx) protected void
SniHandler.replaceHandler
(ChannelHandlerContext ctx, String hostname, SslContext sslContext) The default implementation of this method will simply replacethis
SniHandler
instance with aSslHandler
.private void
SslHandler.safeClose
(ChannelHandlerContext ctx, ChannelFuture flushFuture, ChannelPromise promise) private void
SslClientHelloHandler.select
(ChannelHandlerContext ctx, ByteBuf clientHello) private void
SslHandler.setHandshakeFailure
(ChannelHandlerContext ctx, Throwable cause) Notify all the handshake futures about the failure during the handshake.private void
SslHandler.setHandshakeFailure
(ChannelHandlerContext ctx, Throwable cause, boolean closeInbound, boolean notify, boolean alwaysFlushAndClose) Notify all the handshake futures about the failure during the handshake.private void
SslHandler.setHandshakeFailureTransportFailure
(ChannelHandlerContext ctx, Throwable cause) private int
SslHandler.unwrap
(ChannelHandlerContext ctx, ByteBuf packet, int length) Unwraps inbound SSL records.private int
SslHandler.unwrapNonAppData
(ChannelHandlerContext ctx) CallsSSLEngine.unwrap(ByteBuffer, ByteBuffer)
with an empty buffer to handle handshakes, etc.void
ApplicationProtocolNegotiationHandler.userEventTriggered
(ChannelHandlerContext ctx, Object evt) final void
SslMasterKeyHandler.userEventTriggered
(ChannelHandlerContext ctx, Object evt) private void
SslHandler.wrap
(ChannelHandlerContext ctx, boolean inUnwrap) private void
SslHandler.wrapAndFlush
(ChannelHandlerContext ctx) private boolean
SslHandler.wrapNonAppData
(ChannelHandlerContext ctx, boolean inUnwrap) void
SslClientHelloHandler.write
(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) void
SslHandler.write
(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) -
Uses of ChannelHandlerContext in io.netty.handler.ssl.ocsp
Methods in io.netty.handler.ssl.ocsp with parameters of type ChannelHandlerContextModifier and TypeMethodDescriptionprotected void
OcspHttpHandler.channelRead0
(ChannelHandlerContext ctx, FullHttpResponse response) void
OcspHttpHandler.exceptionCaught
(ChannelHandlerContext ctx, Throwable cause) 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) -
Uses of ChannelHandlerContext in io.netty.handler.stream
Fields in io.netty.handler.stream declared as ChannelHandlerContextMethods in io.netty.handler.stream with parameters of type ChannelHandlerContextModifier and TypeMethodDescriptionvoid
ChunkedWriteHandler.channelInactive
(ChannelHandlerContext ctx) void
ChunkedWriteHandler.channelWritabilityChanged
(ChannelHandlerContext ctx) private void
ChunkedWriteHandler.doFlush
(ChannelHandlerContext ctx) void
ChunkedWriteHandler.flush
(ChannelHandlerContext ctx) void
ChunkedWriteHandler.handlerAdded
(ChannelHandlerContext ctx) ChunkedFile.readChunk
(ChannelHandlerContext ctx) Deprecated.ChunkedInput.readChunk
(ChannelHandlerContext ctx) Deprecated.ChunkedNioFile.readChunk
(ChannelHandlerContext ctx) Deprecated.ChunkedNioStream.readChunk
(ChannelHandlerContext ctx) Deprecated.ChunkedStream.readChunk
(ChannelHandlerContext ctx) Deprecated.private void
ChunkedWriteHandler.resumeTransfer0
(ChannelHandlerContext ctx) void
ChunkedWriteHandler.write
(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) -
Uses of ChannelHandlerContext in io.netty.handler.timeout
Fields in io.netty.handler.timeout declared as ChannelHandlerContextModifier and TypeFieldDescriptionprivate final ChannelHandlerContext
IdleStateHandler.AbstractIdleTask.ctx
private final ChannelHandlerContext
WriteTimeoutHandler.WriteTimeoutTask.ctx
Methods in io.netty.handler.timeout with parameters of type ChannelHandlerContextModifier and TypeMethodDescriptionvoid
IdleStateHandler.channelActive
(ChannelHandlerContext ctx) protected void
IdleStateHandler.channelIdle
(ChannelHandlerContext ctx, IdleStateEvent evt) Is called when anIdleStateEvent
should be fired.protected final void
ReadTimeoutHandler.channelIdle
(ChannelHandlerContext ctx, IdleStateEvent evt) 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
IdleStateHandler.handlerRemoved
(ChannelHandlerContext ctx) void
WriteTimeoutHandler.handlerRemoved
(ChannelHandlerContext ctx) private boolean
IdleStateHandler.hasOutputChanged
(ChannelHandlerContext ctx, boolean first) Returnstrue
if and only if theIdleStateHandler
was constructed withIdleStateHandler.observeOutput
enabled and there has been an observed change in theChannelOutboundBuffer
between two consecutive calls of this method.private void
IdleStateHandler.initialize
(ChannelHandlerContext ctx) private void
IdleStateHandler.initOutputChanged
(ChannelHandlerContext ctx) protected void
ReadTimeoutHandler.readTimedOut
(ChannelHandlerContext ctx) Is called when a read timeout was detected.protected abstract void
IdleStateHandler.AbstractIdleTask.run
(ChannelHandlerContext ctx) protected void
IdleStateHandler.AllIdleTimeoutTask.run
(ChannelHandlerContext ctx) protected void
IdleStateHandler.ReaderIdleTimeoutTask.run
(ChannelHandlerContext ctx) protected void
IdleStateHandler.WriterIdleTimeoutTask.run
(ChannelHandlerContext ctx) (package private) Future
<?> IdleStateHandler.schedule
(ChannelHandlerContext ctx, Runnable task, long delay, TimeUnit unit) This method is visible for testing!private void
WriteTimeoutHandler.scheduleTimeout
(ChannelHandlerContext ctx, ChannelPromise promise) void
IdleStateHandler.write
(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) void
WriteTimeoutHandler.write
(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) protected void
WriteTimeoutHandler.writeTimedOut
(ChannelHandlerContext ctx) Is called when a write timeout was detectedConstructors in io.netty.handler.timeout with parameters of type ChannelHandlerContextModifierConstructorDescription(package private)
(package private)
(package private)
(package private)
(package private)
WriteTimeoutTask
(ChannelHandlerContext ctx, ChannelPromise promise) -
Uses of ChannelHandlerContext in io.netty.handler.traffic
Fields in io.netty.handler.traffic declared as ChannelHandlerContextModifier and TypeFieldDescription(package private) final ChannelHandlerContext
AbstractTrafficShapingHandler.ReopenReadTimerTask.ctx
Methods in io.netty.handler.traffic with parameters of type ChannelHandlerContextModifier and TypeMethodDescriptionvoid
AbstractTrafficShapingHandler.channelRead
(ChannelHandlerContext ctx, Object msg) void
GlobalChannelTrafficShapingHandler.channelRead
(ChannelHandlerContext ctx, Object msg) void
AbstractTrafficShapingHandler.channelRegistered
(ChannelHandlerContext ctx) (package private) long
AbstractTrafficShapingHandler.checkWaitReadTime
(ChannelHandlerContext ctx, long wait, long now) Method overridden in GTSH to take into account specific timer for the channel.protected long
GlobalChannelTrafficShapingHandler.checkWaitReadTime
(ChannelHandlerContext ctx, long wait, long now) (package private) long
GlobalTrafficShapingHandler.checkWaitReadTime
(ChannelHandlerContext ctx, long wait, long now) (package private) void
AbstractTrafficShapingHandler.checkWriteSuspend
(ChannelHandlerContext ctx, long delay, long queueSize) Check the writability according to delay and size for the channel.GlobalChannelTrafficShapingHandler.getOrSetPerChannel
(ChannelHandlerContext ctx) GlobalTrafficShapingHandler.getOrSetPerChannel
(ChannelHandlerContext ctx) void
ChannelTrafficShapingHandler.handlerAdded
(ChannelHandlerContext ctx) void
GlobalChannelTrafficShapingHandler.handlerAdded
(ChannelHandlerContext ctx) void
GlobalTrafficShapingHandler.handlerAdded
(ChannelHandlerContext ctx) void
AbstractTrafficShapingHandler.handlerRemoved
(ChannelHandlerContext ctx) void
ChannelTrafficShapingHandler.handlerRemoved
(ChannelHandlerContext ctx) void
GlobalChannelTrafficShapingHandler.handlerRemoved
(ChannelHandlerContext ctx) void
GlobalTrafficShapingHandler.handlerRemoved
(ChannelHandlerContext ctx) (package private) void
AbstractTrafficShapingHandler.informReadOperation
(ChannelHandlerContext ctx, long now) Method overridden in GTSH to take into account specific timer for the channel.protected void
GlobalChannelTrafficShapingHandler.informReadOperation
(ChannelHandlerContext ctx, long now) (package private) void
GlobalTrafficShapingHandler.informReadOperation
(ChannelHandlerContext ctx, long now) protected static boolean
AbstractTrafficShapingHandler.isHandlerActive
(ChannelHandlerContext ctx) void
AbstractTrafficShapingHandler.read
(ChannelHandlerContext ctx) (package private) void
AbstractTrafficShapingHandler.releaseReadSuspended
(ChannelHandlerContext ctx) Release the Read suspension(package private) void
AbstractTrafficShapingHandler.releaseWriteSuspended
(ChannelHandlerContext ctx) Explicitly release the Write suspended status.private void
ChannelTrafficShapingHandler.sendAllValid
(ChannelHandlerContext ctx, long now) private void
GlobalChannelTrafficShapingHandler.sendAllValid
(ChannelHandlerContext ctx, GlobalChannelTrafficShapingHandler.PerChannel perChannel, long now) private void
GlobalTrafficShapingHandler.sendAllValid
(ChannelHandlerContext ctx, GlobalTrafficShapingHandler.PerChannel perChannel, long now) (package private) void
AbstractTrafficShapingHandler.setUserDefinedWritability
(ChannelHandlerContext ctx, boolean writable) (package private) abstract void
AbstractTrafficShapingHandler.submitWrite
(ChannelHandlerContext ctx, Object msg, long size, long delay, long now, ChannelPromise promise) protected void
AbstractTrafficShapingHandler.submitWrite
(ChannelHandlerContext ctx, Object msg, long delay, ChannelPromise promise) Deprecated.(package private) void
ChannelTrafficShapingHandler.submitWrite
(ChannelHandlerContext ctx, Object msg, long size, long delay, long now, ChannelPromise promise) protected void
GlobalChannelTrafficShapingHandler.submitWrite
(ChannelHandlerContext ctx, Object msg, long size, long writedelay, long now, ChannelPromise promise) (package private) void
GlobalTrafficShapingHandler.submitWrite
(ChannelHandlerContext ctx, Object msg, long size, long writedelay, long now, ChannelPromise promise) void
AbstractTrafficShapingHandler.write
(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) void
GlobalChannelTrafficShapingHandler.write
(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) Constructors in io.netty.handler.traffic with parameters of type ChannelHandlerContext -
Uses of ChannelHandlerContext in io.netty.resolver.dns
Methods in io.netty.resolver.dns with parameters of type ChannelHandlerContextModifier and TypeMethodDescriptionvoid
DnsNameResolver.DnsResponseHandler.channelRead
(ChannelHandlerContext ctx, Object msg) void
DnsNameResolver.DnsResponseHandler.exceptionCaught
(ChannelHandlerContext ctx, Throwable cause)
ChannelInboundHandler
and implement the method there.