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 codec provides asynchronous and non-blocking XML parser based on the
Aalto XML parser.
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 TypeMethodDescriptionvoidServerBootstrap.ServerBootstrapAcceptor.channelRead(ChannelHandlerContext ctx, Object msg) voidServerBootstrap.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) classprivate static class(package private) final class(package private) final class(package private) final classFields in io.netty.channel declared as ChannelHandlerContextModifier and TypeFieldDescriptionprivate final ChannelHandlerContextCombinedChannelDuplexHandler.DelegatingChannelHandlerContext.ctxFields in io.netty.channel with type parameters of type ChannelHandlerContextModifier and TypeFieldDescriptionprivate final Set<ChannelHandlerContext> ChannelInitializer.initMapMethods in io.netty.channel that return ChannelHandlerContextModifier and TypeMethodDescriptionChannelPipeline.context(ChannelHandler handler) Returns the context object of the specifiedChannelHandlerin this pipeline.ChannelPipeline.context(Class<? extends ChannelHandler> handlerType) Returns the context object of theChannelHandlerof the specified type in this pipeline.Returns the context object of theChannelHandlerwith the specified name in this pipeline.final ChannelHandlerContextDefaultChannelPipeline.context(ChannelHandler handler) final ChannelHandlerContextDefaultChannelPipeline.context(Class<? extends ChannelHandler> handlerType) final ChannelHandlerContextAbstractChannelHandlerContext.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 firstChannelHandlerin this pipeline.final ChannelHandlerContextDefaultChannelPipeline.firstContext()AbstractChannelHandlerContext.flush()ChannelHandlerContext.flush()CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.flush()ChannelPipeline.lastContext()Returns the context of the lastChannelHandlerin this pipeline.final ChannelHandlerContextDefaultChannelPipeline.lastContext()AbstractChannelHandlerContext.read()ChannelHandlerContext.read()CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.read()Methods in io.netty.channel with parameters of type ChannelHandlerContextModifier and TypeMethodDescriptionvoidChannelDuplexHandler.bind(ChannelHandlerContext ctx, SocketAddress localAddress, ChannelPromise promise) CallsChannelOutboundInvoker.bind(SocketAddress, ChannelPromise)to forward to the nextChannelOutboundHandlerin theChannelPipeline.voidChannelOutboundHandler.bind(ChannelHandlerContext ctx, SocketAddress localAddress, ChannelPromise promise) Called once a bind operation is made.voidChannelOutboundHandlerAdapter.bind(ChannelHandlerContext ctx, SocketAddress localAddress, ChannelPromise promise) CallsChannelOutboundInvoker.bind(SocketAddress, ChannelPromise)to forward to the nextChannelOutboundHandlerin theChannelPipeline.voidCombinedChannelDuplexHandler.bind(ChannelHandlerContext ctx, SocketAddress localAddress, ChannelPromise promise) voidDefaultChannelPipeline.HeadContext.bind(ChannelHandlerContext ctx, SocketAddress localAddress, ChannelPromise promise) voidChannelInboundHandler.channelActive(ChannelHandlerContext ctx) TheChannelof theChannelHandlerContextis now activevoidChannelInboundHandlerAdapter.channelActive(ChannelHandlerContext ctx) CallsChannelHandlerContext.fireChannelActive()to forward to the nextChannelInboundHandlerin theChannelPipeline.voidCombinedChannelDuplexHandler.channelActive(ChannelHandlerContext ctx) voidDefaultChannelPipeline.HeadContext.channelActive(ChannelHandlerContext ctx) voidDefaultChannelPipeline.TailContext.channelActive(ChannelHandlerContext ctx) voidChannelInboundHandler.channelInactive(ChannelHandlerContext ctx) TheChannelof theChannelHandlerContextwas registered is now inactive and reached its end of lifetime.voidChannelInboundHandlerAdapter.channelInactive(ChannelHandlerContext ctx) CallsChannelHandlerContext.fireChannelInactive()to forward to the nextChannelInboundHandlerin theChannelPipeline.voidCombinedChannelDuplexHandler.channelInactive(ChannelHandlerContext ctx) voidDefaultChannelPipeline.HeadContext.channelInactive(ChannelHandlerContext ctx) voidDefaultChannelPipeline.TailContext.channelInactive(ChannelHandlerContext ctx) voidChannelInboundHandler.channelRead(ChannelHandlerContext ctx, Object msg) Invoked when the currentChannelhas read a message from the peer.voidChannelInboundHandlerAdapter.channelRead(ChannelHandlerContext ctx, Object msg) CallsChannelHandlerContext.fireChannelRead(Object)to forward to the nextChannelInboundHandlerin theChannelPipeline.voidCombinedChannelDuplexHandler.channelRead(ChannelHandlerContext ctx, Object msg) voidDefaultChannelPipeline.HeadContext.channelRead(ChannelHandlerContext ctx, Object msg) voidDefaultChannelPipeline.TailContext.channelRead(ChannelHandlerContext ctx, Object msg) voidSimpleChannelInboundHandler.channelRead(ChannelHandlerContext ctx, Object msg) protected abstract voidSimpleChannelInboundHandler.channelRead0(ChannelHandlerContext ctx, I msg) Is called for each message of typeI.voidChannelInboundHandler.channelReadComplete(ChannelHandlerContext ctx) Invoked when the last message read by the current read operation has been consumed byChannelInboundHandler.channelRead(ChannelHandlerContext, Object).voidChannelInboundHandlerAdapter.channelReadComplete(ChannelHandlerContext ctx) CallsChannelHandlerContext.fireChannelReadComplete()to forward to the nextChannelInboundHandlerin theChannelPipeline.voidCombinedChannelDuplexHandler.channelReadComplete(ChannelHandlerContext ctx) voidDefaultChannelPipeline.HeadContext.channelReadComplete(ChannelHandlerContext ctx) voidDefaultChannelPipeline.TailContext.channelReadComplete(ChannelHandlerContext ctx) voidChannelInboundHandler.channelRegistered(ChannelHandlerContext ctx) voidChannelInboundHandlerAdapter.channelRegistered(ChannelHandlerContext ctx) CallsChannelHandlerContext.fireChannelRegistered()to forward to the nextChannelInboundHandlerin theChannelPipeline.final voidChannelInitializer.channelRegistered(ChannelHandlerContext ctx) voidCombinedChannelDuplexHandler.channelRegistered(ChannelHandlerContext ctx) voidDefaultChannelPipeline.HeadContext.channelRegistered(ChannelHandlerContext ctx) voidDefaultChannelPipeline.TailContext.channelRegistered(ChannelHandlerContext ctx) voidChannelInboundHandler.channelUnregistered(ChannelHandlerContext ctx) voidChannelInboundHandlerAdapter.channelUnregistered(ChannelHandlerContext ctx) CallsChannelHandlerContext.fireChannelUnregistered()to forward to the nextChannelInboundHandlerin theChannelPipeline.voidCombinedChannelDuplexHandler.channelUnregistered(ChannelHandlerContext ctx) voidDefaultChannelPipeline.HeadContext.channelUnregistered(ChannelHandlerContext ctx) voidDefaultChannelPipeline.TailContext.channelUnregistered(ChannelHandlerContext ctx) voidChannelInboundHandler.channelWritabilityChanged(ChannelHandlerContext ctx) Gets called once the writable state of aChannelchanged.voidChannelInboundHandlerAdapter.channelWritabilityChanged(ChannelHandlerContext ctx) CallsChannelHandlerContext.fireChannelWritabilityChanged()to forward to the nextChannelInboundHandlerin theChannelPipeline.voidCombinedChannelDuplexHandler.channelWritabilityChanged(ChannelHandlerContext ctx) voidDefaultChannelPipeline.HeadContext.channelWritabilityChanged(ChannelHandlerContext ctx) voidDefaultChannelPipeline.TailContext.channelWritabilityChanged(ChannelHandlerContext ctx) voidChannelDuplexHandler.close(ChannelHandlerContext ctx, ChannelPromise promise) CallsChannelOutboundInvoker.close(ChannelPromise)to forward to the nextChannelOutboundHandlerin theChannelPipeline.voidChannelOutboundHandler.close(ChannelHandlerContext ctx, ChannelPromise promise) Called once a close operation is made.voidChannelOutboundHandlerAdapter.close(ChannelHandlerContext ctx, ChannelPromise promise) CallsChannelOutboundInvoker.close(ChannelPromise)to forward to the nextChannelOutboundHandlerin theChannelPipeline.voidCombinedChannelDuplexHandler.close(ChannelHandlerContext ctx, ChannelPromise promise) voidDefaultChannelPipeline.HeadContext.close(ChannelHandlerContext ctx, ChannelPromise promise) voidChannelDuplexHandler.connect(ChannelHandlerContext ctx, SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) CallsChannelOutboundInvoker.connect(SocketAddress, SocketAddress, ChannelPromise)to forward to the nextChannelOutboundHandlerin theChannelPipeline.voidChannelOutboundHandler.connect(ChannelHandlerContext ctx, SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) Called once a connect operation is made.voidChannelOutboundHandlerAdapter.connect(ChannelHandlerContext ctx, SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) CallsChannelOutboundInvoker.connect(SocketAddress, SocketAddress, ChannelPromise)to forward to the nextChannelOutboundHandlerin theChannelPipeline.voidCombinedChannelDuplexHandler.connect(ChannelHandlerContext ctx, SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) voidDefaultChannelPipeline.HeadContext.connect(ChannelHandlerContext ctx, SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) voidChannelDuplexHandler.deregister(ChannelHandlerContext ctx, ChannelPromise promise) CallsChannelOutboundInvoker.deregister(ChannelPromise)to forward to the nextChannelOutboundHandlerin theChannelPipeline.voidChannelOutboundHandler.deregister(ChannelHandlerContext ctx, ChannelPromise promise) Called once a deregister operation is made from the current registeredEventLoop.voidChannelOutboundHandlerAdapter.deregister(ChannelHandlerContext ctx, ChannelPromise promise) CallsChannelOutboundInvoker.deregister(ChannelPromise)to forward to the nextChannelOutboundHandlerin theChannelPipeline.voidCombinedChannelDuplexHandler.deregister(ChannelHandlerContext ctx, ChannelPromise promise) voidDefaultChannelPipeline.HeadContext.deregister(ChannelHandlerContext ctx, ChannelPromise promise) voidChannelDuplexHandler.disconnect(ChannelHandlerContext ctx, ChannelPromise promise) CallsChannelOutboundInvoker.disconnect(ChannelPromise)to forward to the nextChannelOutboundHandlerin theChannelPipeline.voidChannelOutboundHandler.disconnect(ChannelHandlerContext ctx, ChannelPromise promise) Called once a disconnect operation is made.voidChannelOutboundHandlerAdapter.disconnect(ChannelHandlerContext ctx, ChannelPromise promise) CallsChannelOutboundInvoker.disconnect(ChannelPromise)to forward to the nextChannelOutboundHandlerin theChannelPipeline.voidCombinedChannelDuplexHandler.disconnect(ChannelHandlerContext ctx, ChannelPromise promise) voidDefaultChannelPipeline.HeadContext.disconnect(ChannelHandlerContext ctx, ChannelPromise promise) protected abstract voidSimpleUserEventChannelHandler.eventReceived(ChannelHandlerContext ctx, I evt) Is called for each user event triggered of typeI.voidChannelHandler.exceptionCaught(ChannelHandlerContext ctx, Throwable cause) Deprecated.voidChannelHandlerAdapter.exceptionCaught(ChannelHandlerContext ctx, Throwable cause) Deprecated.is part ofChannelInboundHandlervoidChannelInboundHandler.exceptionCaught(ChannelHandlerContext ctx, Throwable cause) Gets called if aThrowablewas thrown.voidChannelInboundHandlerAdapter.exceptionCaught(ChannelHandlerContext ctx, Throwable cause) CallsChannelHandlerContext.fireExceptionCaught(Throwable)to forward to the nextChannelHandlerin theChannelPipeline.voidChannelInitializer.exceptionCaught(ChannelHandlerContext ctx, Throwable cause) voidCombinedChannelDuplexHandler.exceptionCaught(ChannelHandlerContext ctx, Throwable cause) voidDefaultChannelPipeline.HeadContext.exceptionCaught(ChannelHandlerContext ctx, Throwable cause) voidDefaultChannelPipeline.TailContext.exceptionCaught(ChannelHandlerContext ctx, Throwable cause) voidChannelDuplexHandler.flush(ChannelHandlerContext ctx) CallsChannelHandlerContext.flush()to forward to the nextChannelOutboundHandlerin theChannelPipeline.voidChannelOutboundHandler.flush(ChannelHandlerContext ctx) Called once a flush operation is made.voidChannelOutboundHandlerAdapter.flush(ChannelHandlerContext ctx) CallsChannelHandlerContext.flush()to forward to the nextChannelOutboundHandlerin theChannelPipeline.voidCombinedChannelDuplexHandler.flush(ChannelHandlerContext ctx) voidDefaultChannelPipeline.HeadContext.flush(ChannelHandlerContext ctx) voidChannelHandler.handlerAdded(ChannelHandlerContext ctx) Gets called after theChannelHandlerwas added to the actual context and it's ready to handle events.voidChannelHandlerAdapter.handlerAdded(ChannelHandlerContext ctx) Do nothing by default, sub-classes may override this method.voidChannelInitializer.handlerAdded(ChannelHandlerContext ctx) Do nothing by default, sub-classes may override this method.voidCombinedChannelDuplexHandler.handlerAdded(ChannelHandlerContext ctx) voidDefaultChannelPipeline.HeadContext.handlerAdded(ChannelHandlerContext ctx) voidDefaultChannelPipeline.TailContext.handlerAdded(ChannelHandlerContext ctx) voidChannelHandler.handlerRemoved(ChannelHandlerContext ctx) Gets called after theChannelHandlerwas removed from the actual context and it doesn't handle events anymore.voidChannelHandlerAdapter.handlerRemoved(ChannelHandlerContext ctx) Do nothing by default, sub-classes may override this method.voidChannelInitializer.handlerRemoved(ChannelHandlerContext ctx) voidCombinedChannelDuplexHandler.handlerRemoved(ChannelHandlerContext ctx) voidDefaultChannelPipeline.HeadContext.handlerRemoved(ChannelHandlerContext ctx) voidDefaultChannelPipeline.TailContext.handlerRemoved(ChannelHandlerContext ctx) private booleanChannelInitializer.initChannel(ChannelHandlerContext ctx) protected voidDefaultChannelPipeline.onUnhandledInboundMessage(ChannelHandlerContext ctx, Object msg) Called once a message hit the end of theChannelPipelinewithout been handled by the user inChannelInboundHandler.channelRead(ChannelHandlerContext, Object).voidChannelDuplexHandler.read(ChannelHandlerContext ctx) CallsChannelHandlerContext.read()to forward to the nextChannelOutboundHandlerin theChannelPipeline.voidChannelOutboundHandler.read(ChannelHandlerContext ctx) InterceptsChannelHandlerContext.read().voidChannelOutboundHandlerAdapter.read(ChannelHandlerContext ctx) CallsChannelHandlerContext.read()to forward to the nextChannelOutboundHandlerin theChannelPipeline.voidCombinedChannelDuplexHandler.read(ChannelHandlerContext ctx) voidDefaultChannelPipeline.HeadContext.read(ChannelHandlerContext ctx) private <T extends ChannelHandler>
TDefaultChannelPipeline.removeIfExists(ChannelHandlerContext ctx) private voidChannelInitializer.removeState(ChannelHandlerContext ctx) voidChannelInboundHandler.userEventTriggered(ChannelHandlerContext ctx, Object evt) Gets called if an user event was triggered.voidChannelInboundHandlerAdapter.userEventTriggered(ChannelHandlerContext ctx, Object evt) CallsChannelHandlerContext.fireUserEventTriggered(Object)to forward to the nextChannelInboundHandlerin theChannelPipeline.voidCombinedChannelDuplexHandler.userEventTriggered(ChannelHandlerContext ctx, Object evt) voidDefaultChannelPipeline.HeadContext.userEventTriggered(ChannelHandlerContext ctx, Object evt) voidDefaultChannelPipeline.TailContext.userEventTriggered(ChannelHandlerContext ctx, Object evt) final voidSimpleUserEventChannelHandler.userEventTriggered(ChannelHandlerContext ctx, Object evt) voidChannelDuplexHandler.write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) CallsChannelOutboundInvoker.write(Object, ChannelPromise)to forward to the nextChannelOutboundHandlerin theChannelPipeline.voidChannelOutboundHandler.write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) Called once a write operation is made.voidChannelOutboundHandlerAdapter.write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) CallsChannelOutboundInvoker.write(Object, ChannelPromise)to forward to the nextChannelOutboundHandlerin theChannelPipeline.voidCombinedChannelDuplexHandler.write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) voidDefaultChannelPipeline.HeadContext.write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) final voidAbstractCoalescingBufferQueue.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 voidEmbeddedChannel.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 voidDynamicAddressConnectHandler.connect(ChannelHandlerContext ctx, SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) voidResolveAddressHandler.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 ByteBufMessageToByteEncoder.allocateBuffer(ChannelHandlerContext ctx, I msg, boolean preferDirect) Allocate aByteBufwhich will be used as argument ofMessageToByteEncoder.encode(ChannelHandlerContext, I, ByteBuf).voidDatagramPacketEncoder.bind(ChannelHandlerContext ctx, SocketAddress localAddress, ChannelPromise promise) protected voidByteToMessageDecoder.callDecode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) Called once data should be decoded from the givenByteBuf.protected voidReplayingDecoder.callDecode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) voidDatagramPacketDecoder.channelActive(ChannelHandlerContext ctx) voidByteToMessageCodec.channelInactive(ChannelHandlerContext ctx) voidByteToMessageDecoder.channelInactive(ChannelHandlerContext ctx) voidDatagramPacketDecoder.channelInactive(ChannelHandlerContext ctx) voidMessageAggregator.channelInactive(ChannelHandlerContext ctx) private voidByteToMessageDecoder.channelInputClosed(ChannelHandlerContext ctx, boolean callChannelInactive) (package private) voidByteToMessageDecoder.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 voidReplayingDecoder.channelInputClosed(ChannelHandlerContext ctx, List<Object> out) voidByteToMessageCodec.channelRead(ChannelHandlerContext ctx, Object msg) voidByteToMessageDecoder.channelRead(ChannelHandlerContext ctx, Object input) voidMessageToMessageCodec.channelRead(ChannelHandlerContext ctx, Object msg) voidMessageToMessageDecoder.channelRead(ChannelHandlerContext ctx, Object msg) voidByteToMessageCodec.channelReadComplete(ChannelHandlerContext ctx) voidByteToMessageDecoder.channelReadComplete(ChannelHandlerContext ctx) voidDatagramPacketDecoder.channelReadComplete(ChannelHandlerContext ctx) voidMessageAggregator.channelReadComplete(ChannelHandlerContext ctx) voidMessageToMessageCodec.channelReadComplete(ChannelHandlerContext ctx) voidMessageToMessageDecoder.channelReadComplete(ChannelHandlerContext ctx) voidDatagramPacketDecoder.channelRegistered(ChannelHandlerContext ctx) voidDatagramPacketDecoder.channelUnregistered(ChannelHandlerContext ctx) voidDatagramPacketDecoder.channelWritabilityChanged(ChannelHandlerContext ctx) voidDatagramPacketEncoder.close(ChannelHandlerContext ctx, ChannelPromise promise) voidDatagramPacketEncoder.connect(ChannelHandlerContext ctx, SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) protected abstract voidByteToMessageCodec.decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) protected abstract voidByteToMessageDecoder.decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) Decode the from oneByteBufto an other.protected voidDatagramPacketDecoder.decode(ChannelHandlerContext ctx, DatagramPacket msg, List<Object> out) protected ObjectDelimiterBasedFrameDecoder.decode(ChannelHandlerContext ctx, ByteBuf buffer) Create a frame out of theByteBufand return it.protected final voidDelimiterBasedFrameDecoder.decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) protected ObjectFixedLengthFrameDecoder.decode(ChannelHandlerContext ctx, ByteBuf in) Create a frame out of theByteBufand return it.protected final voidFixedLengthFrameDecoder.decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) protected ObjectLengthFieldBasedFrameDecoder.decode(ChannelHandlerContext ctx, ByteBuf in) Create a frame out of theByteBufand return it.protected final voidLengthFieldBasedFrameDecoder.decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) protected ObjectLineBasedFrameDecoder.decode(ChannelHandlerContext ctx, ByteBuf buffer) Create a frame out of theByteBufand return it.protected final voidLineBasedFrameDecoder.decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) protected voidMessageAggregator.decode(ChannelHandlerContext ctx, I msg, List<Object> out) protected abstract voidMessageToMessageCodec.decode(ChannelHandlerContext ctx, INBOUND_IN msg, List<Object> out) protected abstract voidMessageToMessageDecoder.decode(ChannelHandlerContext ctx, I msg, List<Object> out) Decode from one message to an other.protected voidByteToMessageCodec.decodeLast(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) protected voidByteToMessageDecoder.decodeLast(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) Is called one last time when theChannelHandlerContextgoes in-active.(package private) final voidByteToMessageDecoder.decodeRemovalReentryProtection(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) Decode the from oneByteBufto an other.voidDatagramPacketEncoder.deregister(ChannelHandlerContext ctx, ChannelPromise promise) voidDatagramPacketEncoder.disconnect(ChannelHandlerContext ctx, ChannelPromise promise) protected abstract voidByteToMessageCodec.encode(ChannelHandlerContext ctx, I msg, ByteBuf out) protected voidByteToMessageCodec.Encoder.encode(ChannelHandlerContext ctx, I msg, ByteBuf out) protected voidDatagramPacketEncoder.encode(ChannelHandlerContext ctx, AddressedEnvelope<M, InetSocketAddress> msg, List<Object> out) protected voidLengthFieldPrepender.encode(ChannelHandlerContext ctx, ByteBuf msg, List<Object> out) protected abstract voidMessageToByteEncoder.encode(ChannelHandlerContext ctx, I msg, ByteBuf out) Encode a message into aByteBuf.protected abstract voidMessageToMessageCodec.encode(ChannelHandlerContext ctx, OUTBOUND_IN msg, List<Object> out) protected abstract voidMessageToMessageEncoder.encode(ChannelHandlerContext ctx, I msg, List<Object> out) Encode from one message to an other.voidDatagramPacketDecoder.exceptionCaught(ChannelHandlerContext ctx, Throwable cause) voidDatagramPacketEncoder.exceptionCaught(ChannelHandlerContext ctx, Throwable cause) protected ByteBufLengthFieldBasedFrameDecoder.extractFrame(ChannelHandlerContext ctx, ByteBuf buffer, int index, int length) Extract the sub-region of the specified buffer.private voidLineBasedFrameDecoder.fail(ChannelHandlerContext ctx, int length) private voidLineBasedFrameDecoder.fail(ChannelHandlerContext ctx, String length) (package private) static voidByteToMessageDecoder.fireChannelRead(ChannelHandlerContext ctx, CodecOutputList msgs, int numElements) GetnumElementsout of theCodecOutputListand forward these through the pipeline.(package private) static voidByteToMessageDecoder.fireChannelRead(ChannelHandlerContext ctx, List<Object> msgs, int numElements) GetnumElementsout of theListand forward these through the pipeline.voidDatagramPacketEncoder.flush(ChannelHandlerContext ctx) protected voidMessageAggregator.handleOversizedMessage(ChannelHandlerContext ctx, S oversized) Invoked when an incoming request exceeds the maximum content length.voidByteToMessageCodec.handlerAdded(ChannelHandlerContext ctx) voidDatagramPacketDecoder.handlerAdded(ChannelHandlerContext ctx) voidDatagramPacketEncoder.handlerAdded(ChannelHandlerContext ctx) voidMessageAggregator.handlerAdded(ChannelHandlerContext ctx) voidByteToMessageCodec.handlerRemoved(ChannelHandlerContext ctx) final voidByteToMessageDecoder.handlerRemoved(ChannelHandlerContext ctx) voidDatagramPacketDecoder.handlerRemoved(ChannelHandlerContext ctx) voidDatagramPacketEncoder.handlerRemoved(ChannelHandlerContext ctx) voidMessageAggregator.handlerRemoved(ChannelHandlerContext ctx) protected voidByteToMessageDecoder.handlerRemoved0(ChannelHandlerContext ctx) Gets called after theByteToMessageDecoderwas removed from the actual context and it doesn't handle events anymore.private voidMessageAggregator.invokeHandleOversizedMessage(ChannelHandlerContext ctx, S oversized) voidDatagramPacketEncoder.read(ChannelHandlerContext ctx) voidByteToMessageDecoder.userEventTriggered(ChannelHandlerContext ctx, Object evt) voidDatagramPacketDecoder.userEventTriggered(ChannelHandlerContext ctx, Object evt) voidByteToMessageCodec.write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) voidMessageToByteEncoder.write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) voidMessageToMessageCodec.write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) voidMessageToMessageEncoder.write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) private static voidMessageToMessageEncoder.writePromiseCombiner(ChannelHandlerContext ctx, CodecOutputList out, ChannelPromise promise) private static voidMessageToMessageEncoder.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 voidBase64Decoder.decode(ChannelHandlerContext ctx, ByteBuf msg, List<Object> out) protected voidBase64Encoder.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 voidByteArrayDecoder.decode(ChannelHandlerContext ctx, ByteBuf msg, List<Object> out) protected voidByteArrayEncoder.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 ChannelHandlerContextBzip2Encoder.ctxUsed to interact with itsChannelPipelineand other handlers.private ChannelHandlerContextJdkZlibEncoder.ctxprivate ChannelHandlerContextJZlibEncoder.ctxMethods in io.netty.handler.codec.compression that return ChannelHandlerContextModifier and TypeMethodDescriptionprivate ChannelHandlerContextBzip2Encoder.ctx()private ChannelHandlerContextJdkZlibEncoder.ctx()private ChannelHandlerContextJZlibEncoder.ctx()Methods in io.netty.handler.codec.compression with parameters of type ChannelHandlerContextModifier and TypeMethodDescriptionprotected final ByteBufJdkZlibEncoder.allocateBuffer(ChannelHandlerContext ctx, ByteBuf msg, boolean preferDirect) voidJdkZlibDecoder.channelReadComplete(ChannelHandlerContext ctx) voidJZlibDecoder.channelReadComplete(ChannelHandlerContext ctx) voidBzip2Encoder.close(ChannelHandlerContext ctx, ChannelPromise promise) voidJdkZlibEncoder.close(ChannelHandlerContext ctx, ChannelPromise promise) voidJZlibEncoder.close(ChannelHandlerContext ctx, ChannelPromise promise) (package private) static voidEncoderUtil.closeAfterFinishEncode(ChannelHandlerContext ctx, ChannelFuture finishFuture, ChannelPromise promise) protected voidBzip2Decoder.decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) protected voidFastLzFrameDecoder.decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) protected voidJdkZlibDecoder.decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) protected voidJZlibDecoder.decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) protected voidSnappyFrameDecoder.decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) protected voidBzip2Encoder.encode(ChannelHandlerContext ctx, ByteBuf in, ByteBuf out) protected voidFastLzFrameEncoder.encode(ChannelHandlerContext ctx, ByteBuf in, ByteBuf out) protected voidJdkZlibEncoder.encode(ChannelHandlerContext ctx, ByteBuf uncompressed, ByteBuf out) protected voidJZlibEncoder.encode(ChannelHandlerContext ctx, ByteBuf in, ByteBuf out) protected voidSnappyFrameEncoder.encode(ChannelHandlerContext ctx, ByteBuf in, ByteBuf out) private ChannelFutureBzip2Encoder.finishEncode(ChannelHandlerContext ctx, ChannelPromise promise) private ChannelFutureJdkZlibEncoder.finishEncode(ChannelHandlerContext ctx, ChannelPromise promise) private ChannelFutureJZlibEncoder.finishEncode(ChannelHandlerContext ctx, ChannelPromise promise) voidBzip2Encoder.handlerAdded(ChannelHandlerContext ctx) voidJdkZlibEncoder.handlerAdded(ChannelHandlerContext ctx) voidJZlibEncoder.handlerAdded(ChannelHandlerContext ctx) protected voidJdkZlibDecoder.handlerRemoved0(ChannelHandlerContext ctx) protected ByteBufZlibDecoder.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 ByteBufDatagramDnsQueryEncoder.allocateBuffer(ChannelHandlerContext ctx, AddressedEnvelope<DnsQuery, InetSocketAddress> msg) Allocate aByteBufwhich will be used for constructing a datagram packet.protected ByteBufDatagramDnsResponseEncoder.allocateBuffer(ChannelHandlerContext ctx, AddressedEnvelope<DnsResponse, InetSocketAddress> msg) Allocate aByteBufwhich will be used for constructing a datagram packet.protected ByteBufTcpDnsQueryEncoder.allocateBuffer(ChannelHandlerContext ctx, DnsQuery msg, boolean preferDirect) protected voidDatagramDnsQueryDecoder.decode(ChannelHandlerContext ctx, DatagramPacket packet, List<Object> out) protected voidDatagramDnsResponseDecoder.decode(ChannelHandlerContext ctx, DatagramPacket packet, List<Object> out) protected ObjectTcpDnsQueryDecoder.decode(ChannelHandlerContext ctx, ByteBuf in) protected ObjectTcpDnsResponseDecoder.decode(ChannelHandlerContext ctx, ByteBuf in) protected DnsResponseDatagramDnsResponseDecoder.decodeResponse(ChannelHandlerContext ctx, DatagramPacket packet) protected voidDatagramDnsQueryEncoder.encode(ChannelHandlerContext ctx, AddressedEnvelope<DnsQuery, InetSocketAddress> in, List<Object> out) protected voidDatagramDnsResponseEncoder.encode(ChannelHandlerContext ctx, AddressedEnvelope<DnsResponse, InetSocketAddress> in, List<Object> out) protected voidTcpDnsQueryEncoder.encode(ChannelHandlerContext ctx, DnsQuery msg, ByteBuf out) protected voidTcpDnsResponseEncoder.encode(ChannelHandlerContext ctx, DnsResponse response, List<Object> out) protected ByteBufTcpDnsResponseDecoder.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 TypeMethodDescriptionvoidHAProxyMessageDecoder.channelRead(ChannelHandlerContext ctx, Object msg) protected final voidHAProxyMessageDecoder.decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) private ByteBufHAProxyMessageDecoder.decodeLine(ChannelHandlerContext ctx, ByteBuf buffer) Create a frame out of theByteBufand return it.private ByteBufHAProxyMessageDecoder.decodeStruct(ChannelHandlerContext ctx, ByteBuf buffer) Create a frame out of theByteBufand return it.protected voidHAProxyMessageEncoder.encode(ChannelHandlerContext ctx, HAProxyMessage msg, ByteBuf out) HAProxyMessageDecoder.HeaderExtractor.extract(ChannelHandlerContext ctx, ByteBuf buffer) Create a frame out of theByteBufand return it.private voidHAProxyMessageDecoder.fail(ChannelHandlerContext ctx, String errMsg, Exception e) private voidHAProxyMessageDecoder.failOverLimit(ChannelHandlerContext ctx, int length) private voidHAProxyMessageDecoder.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 ChannelHandlerContextHttpContentCompressor.ctxprotected ChannelHandlerContextHttpContentDecoder.ctxprivate final ChannelHandlerContextHttpContentDecoder.ByteBufForwarder.targetCtxMethods in io.netty.handler.codec.http with parameters of type ChannelHandlerContextModifier and TypeMethodDescriptionprivate static voidHttpObjectEncoder.addEncodedLengthHex(ChannelHandlerContext ctx, long contentLength, List<Object> out) voidHttpClientUpgradeHandler.bind(ChannelHandlerContext ctx, SocketAddress localAddress, ChannelPromise promise) voidHttpClientCodec.Decoder.channelInactive(ChannelHandlerContext ctx) voidHttpContentDecoder.channelInactive(ChannelHandlerContext ctx) voidHttpContentEncoder.channelInactive(ChannelHandlerContext ctx) voidHttpContentDecoder.ByteBufForwarder.channelRead(ChannelHandlerContext ctx, Object msg) voidHttpServerExpectContinueHandler.channelRead(ChannelHandlerContext ctx, Object msg) voidHttpServerKeepAliveHandler.channelRead(ChannelHandlerContext ctx, Object msg) voidHttpContentDecoder.channelReadComplete(ChannelHandlerContext ctx) private voidHttpContentDecoder.cleanupSafely(ChannelHandlerContext ctx) private voidHttpContentEncoder.cleanupSafely(ChannelHandlerContext ctx) voidHttpClientUpgradeHandler.close(ChannelHandlerContext ctx, ChannelPromise promise) voidHttpClientUpgradeHandler.connect(ChannelHandlerContext ctx, SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) protected voidHttpClientCodec.Decoder.decode(ChannelHandlerContext ctx, ByteBuf buffer, List<Object> out) protected voidHttpClientUpgradeHandler.decode(ChannelHandlerContext ctx, HttpObject msg, List<Object> out) protected voidHttpContentDecoder.decode(ChannelHandlerContext ctx, HttpObject msg, List<Object> out) protected voidHttpContentEncoder.decode(ChannelHandlerContext ctx, HttpRequest msg, List<Object> out) protected voidHttpObjectDecoder.decode(ChannelHandlerContext ctx, ByteBuf buffer, List<Object> out) protected voidHttpServerCodec.HttpServerRequestDecoder.decode(ChannelHandlerContext ctx, ByteBuf buffer, List<Object> out) protected voidHttpServerUpgradeHandler.decode(ChannelHandlerContext ctx, HttpObject msg, List<Object> out) protected voidHttpObjectDecoder.decodeLast(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) voidHttpClientUpgradeHandler.deregister(ChannelHandlerContext ctx, ChannelPromise promise) voidHttpClientUpgradeHandler.disconnect(ChannelHandlerContext ctx, ChannelPromise promise) protected voidHttpClientCodec.Encoder.encode(ChannelHandlerContext ctx, Object msg, List<Object> out) protected voidHttpContentEncoder.encode(ChannelHandlerContext ctx, HttpObject msg, List<Object> out) protected voidHttpObjectEncoder.encode(ChannelHandlerContext ctx, Object msg, List<Object> out) private voidHttpObjectEncoder.encodeByteBufAndTrailers(int state, ChannelHandlerContext ctx, List<Object> out, ByteBuf content, HttpHeaders trailingHeaders) private voidHttpObjectEncoder.encodeByteBufContent(ChannelHandlerContext ctx, ByteBuf content, List<Object> out) private voidHttpObjectEncoder.encodeByteBufHttpContent(int state, ChannelHandlerContext ctx, ByteBuf buf, ByteBuf content, HttpHeaders trailingHeaders, List<Object> out) private voidHttpObjectEncoder.encodeChunkedHttpContent(ChannelHandlerContext ctx, ByteBuf content, HttpHeaders trailingHeaders, List<Object> out) private static voidHttpObjectEncoder.encodedChunkedFileRegionContent(ChannelHandlerContext ctx, FileRegion msg, List<Object> out) private voidHttpObjectEncoder.encodeFileRegionContent(ChannelHandlerContext ctx, FileRegion msg, List<Object> out) private voidHttpObjectEncoder.encodeFullHttpMessage(ChannelHandlerContext ctx, Object o, List<Object> out) private voidHttpObjectEncoder.encodeHttpContent(ChannelHandlerContext ctx, HttpContent msg, List<Object> out) private voidHttpObjectEncoder.encodeHttpMessageLastContent(ChannelHandlerContext ctx, H m, List<Object> out) private voidHttpObjectEncoder.encodeHttpMessageNotLastContent(ChannelHandlerContext ctx, H m, List<Object> out) private ByteBufHttpObjectEncoder.encodeInitHttpMessage(ChannelHandlerContext ctx, H m) private voidHttpObjectEncoder.encodeJustHttpMessage(ChannelHandlerContext ctx, H m, List<Object> out) private voidHttpObjectEncoder.encodeLastHttpContent(ChannelHandlerContext ctx, LastHttpContent msg, List<Object> out) private voidHttpObjectEncoder.encodeNotHttpMessageContentTypes(ChannelHandlerContext ctx, Object msg, List<Object> out) private voidHttpObjectEncoder.encodeTrailingHeaders(ChannelHandlerContext ctx, HttpHeaders trailingHeaders, List<Object> out) voidHttpClientUpgradeHandler.flush(ChannelHandlerContext ctx) protected voidHttpObjectAggregator.handleOversizedMessage(ChannelHandlerContext ctx, HttpMessage oversized) voidHttpContentCompressor.handlerAdded(ChannelHandlerContext ctx) voidHttpContentDecoder.handlerAdded(ChannelHandlerContext ctx) voidHttpContentDecoder.handlerRemoved(ChannelHandlerContext ctx) voidHttpContentEncoder.handlerRemoved(ChannelHandlerContext ctx) protected voidHttpObjectDecoder.handlerRemoved0(ChannelHandlerContext ctx) voidHttpClientCodec.prepareUpgradeFrom(ChannelHandlerContext ctx) Prepares to upgrade to another protocol from HTTP.voidHttpClientUpgradeHandler.SourceCodec.prepareUpgradeFrom(ChannelHandlerContext ctx) Removes or disables the encoder of this codec so that theHttpClientUpgradeHandler.UpgradeCodeccan send an initial greeting (if any).booleanHttpServerUpgradeHandler.UpgradeCodec.prepareUpgradeResponse(ChannelHandlerContext ctx, FullHttpRequest upgradeRequest, HttpHeaders upgradeHeaders) Prepares theupgradeHeadersfor a protocol update based upon the contents ofupgradeRequest.voidHttpClientUpgradeHandler.read(ChannelHandlerContext ctx) HttpChunkedInput.readChunk(ChannelHandlerContext ctx) Deprecated.private static voidHttpClientUpgradeHandler.removeThisHandler(ChannelHandlerContext ctx) HttpClientUpgradeHandler.UpgradeCodec.setUpgradeHeaders(ChannelHandlerContext ctx, HttpRequest upgradeRequest) Sets any protocol-specific headers required to the upgrade request.private voidHttpClientUpgradeHandler.setUpgradeRequestHeaders(ChannelHandlerContext ctx, HttpRequest request) Adds all upgrade request headers necessary for an upgrade to the supported protocols.private booleanHttpServerUpgradeHandler.upgrade(ChannelHandlerContext ctx, FullHttpRequest request) Attempts to upgrade to the protocol(s) identified by theHttpHeaderNames.UPGRADEheader (if provided in the request).voidHttpClientCodec.upgradeFrom(ChannelHandlerContext ctx) Upgrades to another protocol from HTTP.voidHttpClientUpgradeHandler.SourceCodec.upgradeFrom(ChannelHandlerContext ctx) Removes this codec (i.e.voidHttpServerCodec.upgradeFrom(ChannelHandlerContext ctx) Upgrades to another protocol from HTTP.voidHttpServerUpgradeHandler.SourceCodec.upgradeFrom(ChannelHandlerContext ctx) Removes this codec (i.e.voidHttpClientUpgradeHandler.UpgradeCodec.upgradeTo(ChannelHandlerContext ctx, FullHttpResponse upgradeResponse) Performs an HTTP protocol upgrade from the source codec.voidHttpServerUpgradeHandler.UpgradeCodec.upgradeTo(ChannelHandlerContext ctx, FullHttpRequest upgradeRequest) Performs an HTTP protocol upgrade from the source codec.voidHttpObjectDecoder.userEventTriggered(ChannelHandlerContext ctx, Object evt) voidHttpClientUpgradeHandler.write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) voidHttpObjectEncoder.write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) voidHttpServerKeepAliveHandler.write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) private static voidHttpObjectEncoder.writeOutList(ChannelHandlerContext ctx, List<Object> out, ChannelPromise promise) private static voidHttpObjectEncoder.writePromiseCombiner(ChannelHandlerContext ctx, List<Object> out, ChannelPromise promise) private static voidHttpObjectEncoder.writeVoidPromise(ChannelHandlerContext ctx, List<Object> out) Constructors in io.netty.handler.codec.http with parameters of type ChannelHandlerContextModifierConstructorDescription(package private)ByteBufForwarder(ChannelHandlerContext targetCtx) -
Uses of ChannelHandlerContext in io.netty.handler.codec.http.cors
Methods in io.netty.handler.codec.http.cors with parameters of type ChannelHandlerContextModifier and TypeMethodDescriptionvoidCorsHandler.channelRead(ChannelHandlerContext ctx, Object msg) private static voidCorsHandler.forbidden(ChannelHandlerContext ctx, HttpRequest request) private voidCorsHandler.handlePreflight(ChannelHandlerContext ctx, HttpRequest request) private static voidCorsHandler.respond(ChannelHandlerContext ctx, HttpRequest request, HttpResponse response) voidCorsHandler.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 ChannelHandlerContextWebSocketClientProtocolHandshakeHandler.ctxprivate ChannelHandlerContextWebSocketServerProtocolHandshakeHandler.ctxMethods in io.netty.handler.codec.http.websocketx with parameters of type ChannelHandlerContextModifier and TypeMethodDescriptionprivate voidWebSocketProtocolHandler.applyCloseSentTimeout(ChannelHandlerContext ctx) voidWebSocketProtocolHandler.bind(ChannelHandlerContext ctx, SocketAddress localAddress, ChannelPromise promise) voidWebSocketClientProtocolHandshakeHandler.channelActive(ChannelHandlerContext ctx) voidWebSocketClientProtocolHandshakeHandler.channelInactive(ChannelHandlerContext ctx) voidUtf8FrameValidator.channelRead(ChannelHandlerContext ctx, Object msg) voidWebSocketClientProtocolHandshakeHandler.channelRead(ChannelHandlerContext ctx, Object msg) voidWebSocketServerProtocolHandshakeHandler.channelRead(ChannelHandlerContext ctx, Object msg) protected voidWebSocket08FrameDecoder.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 handshakevoidWebSocketProtocolHandler.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 framevoidWebSocketProtocolHandler.connect(ChannelHandlerContext ctx, SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) protected voidWebSocket00FrameDecoder.decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) protected voidWebSocket08FrameDecoder.decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) protected voidWebSocketClientProtocolHandler.decode(ChannelHandlerContext ctx, WebSocketFrame frame, List<Object> out) protected voidWebSocketProtocolHandler.decode(ChannelHandlerContext ctx, WebSocketFrame frame, List<Object> out) protected voidWebSocketServerProtocolHandler.decode(ChannelHandlerContext ctx, WebSocketFrame frame, List<Object> out) private WebSocketFrameWebSocket00FrameDecoder.decodeBinaryFrame(ChannelHandlerContext ctx, byte type, ByteBuf buffer) private WebSocketFrameWebSocket00FrameDecoder.decodeTextFrame(ChannelHandlerContext ctx, ByteBuf buffer) voidWebSocketProtocolHandler.deregister(ChannelHandlerContext ctx, ChannelPromise promise) voidWebSocketProtocolHandler.disconnect(ChannelHandlerContext ctx, ChannelPromise promise) protected voidWebSocket00FrameEncoder.encode(ChannelHandlerContext ctx, WebSocketFrame msg, List<Object> out) protected voidWebSocket08FrameEncoder.encode(ChannelHandlerContext ctx, WebSocketFrame msg, List<Object> out) voidUtf8FrameValidator.exceptionCaught(ChannelHandlerContext ctx, Throwable cause) voidWebSocketProtocolHandler.exceptionCaught(ChannelHandlerContext ctx, Throwable cause) voidWebSocketServerProtocolHandler.exceptionCaught(ChannelHandlerContext ctx, Throwable cause) voidWebSocketProtocolHandler.flush(ChannelHandlerContext ctx) voidWebSocketClientProtocolHandler.handlerAdded(ChannelHandlerContext ctx) voidWebSocketClientProtocolHandshakeHandler.handlerAdded(ChannelHandlerContext ctx) voidWebSocketServerProtocolHandler.handlerAdded(ChannelHandlerContext ctx) voidWebSocketServerProtocolHandshakeHandler.handlerAdded(ChannelHandlerContext ctx) private voidUtf8FrameValidator.protocolViolation(ChannelHandlerContext ctx, WebSocketFrame frame, CorruptedWebSocketFrameException ex) private voidWebSocket08FrameDecoder.protocolViolation(ChannelHandlerContext ctx, ByteBuf in, CorruptedWebSocketFrameException ex) private voidWebSocket08FrameDecoder.protocolViolation(ChannelHandlerContext ctx, ByteBuf in, WebSocketCloseStatus status, String reason) private voidWebSocket08FrameDecoder.protocolViolation(ChannelHandlerContext ctx, ByteBuf in, String reason) voidWebSocketProtocolHandler.read(ChannelHandlerContext ctx) WebSocketChunkedInput.readChunk(ChannelHandlerContext ctx) Deprecated.private static voidWebSocketProtocolHandler.readIfNeeded(ChannelHandlerContext ctx) private static voidWebSocketServerProtocolHandshakeHandler.sendHttpResponse(ChannelHandlerContext ctx, HttpRequest req, HttpResponse res) voidWebSocketProtocolHandler.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 TypeMethodDescriptionvoidWebSocketClientExtensionHandler.channelRead(ChannelHandlerContext ctx, Object msg) voidWebSocketServerExtensionHandler.channelRead(ChannelHandlerContext ctx, Object msg) private voidWebSocketServerExtensionHandler.handlePotentialUpgrade(ChannelHandlerContext ctx, ChannelPromise promise, HttpResponse httpResponse, List<WebSocketServerExtension> validExtensionsList) protected voidWebSocketServerExtensionHandler.onHttpRequestChannelRead(ChannelHandlerContext ctx, HttpRequest request) This is a method exposed to perform fail-fast checks of user-defined http types.protected voidWebSocketServerExtensionHandler.onHttpResponseWrite(ChannelHandlerContext ctx, HttpResponse response, ChannelPromise promise) This is a method exposed to perform fail-fast checks of user-defined http types.voidWebSocketClientExtensionHandler.write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) voidWebSocketServerExtensionHandler.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 TypeMethodDescriptionvoidDeflateDecoder.channelInactive(ChannelHandlerContext ctx) private ByteBufDeflateEncoder.compressContent(ChannelHandlerContext ctx, WebSocketFrame msg) protected voidDeflateDecoder.decode(ChannelHandlerContext ctx, WebSocketFrame msg, List<Object> out) protected voidPerMessageDeflateDecoder.decode(ChannelHandlerContext ctx, WebSocketFrame msg, List<Object> out) private ByteBufDeflateDecoder.decompressContent(ChannelHandlerContext ctx, WebSocketFrame msg) protected voidDeflateEncoder.encode(ChannelHandlerContext ctx, WebSocketFrame msg, List<Object> out) protected voidPerMessageDeflateEncoder.encode(ChannelHandlerContext ctx, WebSocketFrame msg, List<Object> out) voidDeflateDecoder.handlerRemoved(ChannelHandlerContext ctx) voidDeflateEncoder.handlerRemoved(ChannelHandlerContext ctx) -
Uses of ChannelHandlerContext in io.netty.handler.codec.http2
Fields in io.netty.handler.codec.http2 declared as ChannelHandlerContextModifier and TypeFieldDescriptionprivate ChannelHandlerContextDefaultHttp2LocalFlowController.ctxprivate ChannelHandlerContextDefaultHttp2RemoteFlowController.ctxprivate final ChannelHandlerContextHttp2ConnectionHandler.ClosingChannelFutureListener.ctx(package private) ChannelHandlerContextHttp2FrameCodec.ctx(package private) ChannelHandlerContextHttp2MultiplexCodec.ctxDeprecated.private ChannelHandlerContextHttp2MultiplexHandler.ctx(package private) final ChannelHandlerContextStreamBufferingEncoder.PendingStream.ctxprivate ChannelHandlerContextHttp2StreamChannelBootstrap.multiplexCtxprivate ChannelHandlerContextDelegatingDecompressorFrameListener.Http2Decompressor.targetCtxMethods in io.netty.handler.codec.http2 that return ChannelHandlerContextModifier and TypeMethodDescriptionDefaultHttp2RemoteFlowController.channelHandlerContext()Http2RemoteFlowController.channelHandlerContext()Get theChannelHandlerContextfor which to apply flow control on.private ChannelHandlerContextHttp2StreamChannelBootstrap.findCtx()protected abstract ChannelHandlerContextAbstractHttp2StreamChannel.parentContext()protected ChannelHandlerContextHttp2MultiplexCodec.Http2MultiplexCodecStreamChannel.parentContext()protected ChannelHandlerContextHttp2MultiplexHandler.Http2MultiplexHandlerStreamChannel.parentContext()Methods in io.netty.handler.codec.http2 with parameters of type ChannelHandlerContextModifier and TypeMethodDescriptionvoidHttp2ConnectionHandler.bind(ChannelHandlerContext ctx, SocketAddress localAddress, ChannelPromise promise) voidHttp2ConnectionHandler.BaseDecoder.channelActive(ChannelHandlerContext ctx) voidHttp2ConnectionHandler.channelActive(ChannelHandlerContext ctx) voidHttp2ConnectionHandler.PrefaceDecoder.channelActive(ChannelHandlerContext ctx) voidDefaultHttp2LocalFlowController.channelHandlerContext(ChannelHandlerContext ctx) voidDefaultHttp2RemoteFlowController.channelHandlerContext(ChannelHandlerContext ctx) Set theChannelHandlerContextfor which to apply flow control on.voidDelegatingDecompressorFrameListener.ConsumedBytesConverter.channelHandlerContext(ChannelHandlerContext ctx) voidHttp2FlowController.channelHandlerContext(ChannelHandlerContext ctx) Set theChannelHandlerContextfor which to apply flow control on.voidHttp2ConnectionHandler.BaseDecoder.channelInactive(ChannelHandlerContext ctx) voidHttp2ConnectionHandler.channelInactive(ChannelHandlerContext ctx) voidHttp2ConnectionHandler.PrefaceDecoder.channelInactive(ChannelHandlerContext ctx) final voidHttp2MultiplexCodec.channelRead(ChannelHandlerContext ctx, Object msg) Deprecated.voidHttp2MultiplexHandler.channelRead(ChannelHandlerContext ctx, Object msg) voidInboundHttpToHttp2Adapter.channelRead(ChannelHandlerContext ctx, Object msg) voidHttp2ConnectionHandler.channelReadComplete(ChannelHandlerContext ctx) final voidHttp2MultiplexCodec.channelReadComplete(ChannelHandlerContext ctx) Deprecated.Notifies any child streams of the read completion.voidHttp2MultiplexHandler.channelReadComplete(ChannelHandlerContext ctx) Notifies any child streams of the read completion.(package private) final voidHttp2ConnectionHandler.channelReadComplete0(ChannelHandlerContext ctx) voidHttp2ConnectionHandler.channelWritabilityChanged(ChannelHandlerContext ctx) final voidHttp2MultiplexCodec.channelWritabilityChanged(ChannelHandlerContext ctx) Deprecated.voidHttp2MultiplexHandler.channelWritabilityChanged(ChannelHandlerContext ctx) voidHttp2ConnectionHandler.close(ChannelHandlerContext ctx, ChannelPromise promise) private voidHttp2ConnectionHandler.closeConnectionOnError(ChannelHandlerContext ctx, ChannelFuture future) voidHttp2ConnectionHandler.connect(ChannelHandlerContext ctx, SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) private static ChannelHttp2StreamFrameToHttpObjectCodec.connectionChannel(ChannelHandlerContext ctx) private static HttpSchemeHttp2StreamFrameToHttpObjectCodec.connectionScheme(ChannelHandlerContext ctx) private static Attribute<HttpScheme> Http2StreamFrameToHttpObjectCodec.connectionSchemeAttribute(ChannelHandlerContext ctx) private static ByteBufHttp2ServerUpgradeCodec.createSettingsFrame(ChannelHandlerContext ctx, ByteBuf payload) Creates an HTTP2-Settings header with the given payload.protected voidCleartextHttp2ServerUpgradeHandler.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 voidHttp2ConnectionHandler.BaseDecoder.decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) protected voidHttp2ConnectionHandler.decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) voidHttp2ConnectionHandler.FrameDecoder.decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) voidHttp2ConnectionHandler.PrefaceDecoder.decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) protected voidHttp2StreamFrameToHttpObjectCodec.decode(ChannelHandlerContext ctx, Http2StreamFrame frame, List<Object> out) voidDecoratingHttp2ConnectionDecoder.decodeFrame(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) voidDefaultHttp2ConnectionDecoder.decodeFrame(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) voidHttp2ConnectionDecoder.decodeFrame(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) Called by theHttp2ConnectionHandlerto decode the next frame from the input buffer.private Http2SettingsHttp2ServerUpgradeCodec.decodeSettings(ChannelHandlerContext ctx, ByteBuf frame) Decodes the settings frame and returns the settings.private Http2SettingsHttp2ServerUpgradeCodec.decodeSettingsHeader(ChannelHandlerContext ctx, CharSequence settingsHeader) Decodes the settings header and returns aHttp2Settingsobject.(package private) intDelegatingDecompressorFrameListener.Http2Decompressor.decompress(ChannelHandlerContext ctx, Http2Stream stream, ByteBuf data, int padding, boolean endOfStream) voidHttp2ConnectionHandler.deregister(ChannelHandlerContext ctx, ChannelPromise promise) voidHttp2ConnectionHandler.disconnect(ChannelHandlerContext ctx, ChannelPromise promise) private voidHttp2ConnectionHandler.doGracefulShutdown(ChannelHandlerContext ctx, ChannelFuture future, ChannelPromise promise) protected voidHttp2StreamFrameToHttpObjectCodec.encode(ChannelHandlerContext ctx, HttpObject obj, List<Object> out) Encode from anHttpObjectto anHttp2StreamFrame.voidDefaultHttp2ConnectionEncoder.FlowControlledData.error(ChannelHandlerContext ctx, Throwable cause) voidDefaultHttp2ConnectionEncoder.FlowControlledHeaders.error(ChannelHandlerContext ctx, Throwable cause) voidHttp2RemoteFlowController.FlowControlled.error(ChannelHandlerContext ctx, Throwable cause) Called to indicate that an error occurred before this object could be completely written.voidHttp2ConnectionHandler.exceptionCaught(ChannelHandlerContext ctx, Throwable cause) HandlesHttp2Exceptionobjects that were thrown from other handlers.voidHttp2MultiplexHandler.exceptionCaught(ChannelHandlerContext ctx, Throwable cause) protected voidInboundHttp2ToHttpAdapter.fireChannelRead(ChannelHandlerContext ctx, FullHttpMessage msg, boolean release, Http2Stream stream) Set final headers and fire a channel read eventvoidHttp2ConnectionHandler.flush(ChannelHandlerContext ctx) protected voidAbstractHttp2StreamChannel.flush0(ChannelHandlerContext ctx) (package private) final voidHttp2MultiplexCodec.flush0(ChannelHandlerContext ctx) Deprecated.protected voidHttp2MultiplexCodec.Http2MultiplexCodecStreamChannel.flush0(ChannelHandlerContext ctx) private CharSequenceHttp2ClientUpgradeCodec.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 ChannelFutureHttp2ConnectionHandler.goAway(ChannelHandlerContext ctx, Http2Exception cause, ChannelPromise promise) Close the remote endpoint with aGO_AWAYframe.Http2LifecycleManager.goAway(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData, ChannelPromise promise) Prevents the peer from creating streams and close the connection iferrorCodeis notHttp2Error.NO_ERROR.(package private) static voidInboundHttpToHttp2Adapter.handle(ChannelHandlerContext ctx, Http2Connection connection, Http2FrameListener listener, FullHttpMessage message) private ChannelPromiseHttp2ControlFrameLimitEncoder.handleOutstandingControlFrames(ChannelHandlerContext ctx, ChannelPromise promise) voidCleartextHttp2ServerUpgradeHandler.handlerAdded(ChannelHandlerContext ctx) final voidHttp2ChannelDuplexHandler.handlerAdded(ChannelHandlerContext ctx) voidHttp2ConnectionHandler.handlerAdded(ChannelHandlerContext ctx) final voidHttp2FrameCodec.handlerAdded(ChannelHandlerContext ctx) voidHttp2StreamFrameToHttpObjectCodec.handlerAdded(ChannelHandlerContext ctx) protected voidHttp2ChannelDuplexHandler.handlerAdded0(ChannelHandlerContext ctx) (package private) voidHttp2FrameCodec.handlerAdded0(ChannelHandlerContext ctx) final voidHttp2MultiplexCodec.handlerAdded0(ChannelHandlerContext ctx) Deprecated.protected voidHttp2MultiplexHandler.handlerAdded0(ChannelHandlerContext ctx) final voidHttp2ChannelDuplexHandler.handlerRemoved(ChannelHandlerContext ctx) voidHttp2ConnectionHandler.BaseDecoder.handlerRemoved(ChannelHandlerContext ctx) voidHttp2ConnectionHandler.PrefaceDecoder.handlerRemoved(ChannelHandlerContext ctx) Releases theclientPrefaceString.protected voidHttp2ChannelDuplexHandler.handlerRemoved0(ChannelHandlerContext ctx) protected voidHttp2ConnectionHandler.handlerRemoved0(ChannelHandlerContext ctx) final voidHttp2MultiplexCodec.handlerRemoved0(ChannelHandlerContext ctx) Deprecated.protected voidHttp2MultiplexHandler.handlerRemoved0(ChannelHandlerContext ctx) protected voidHttp2ConnectionHandler.handleServerHeaderDecodeSizeError(ChannelHandlerContext ctx, Http2Stream stream) Notifies client that this server has received headers that are larger than what it is willing to accept.private voidDelegatingDecompressorFrameListener.initDecompressor(ChannelHandlerContext ctx, int streamId, Http2Headers headers, boolean endOfStream) Checks if a new decompressor object is needed for the stream identified bystreamId.private booleanHttp2FrameCodec.initializeNewStream(ChannelHandlerContext ctx, Http2FrameCodec.DefaultHttp2FrameStream http2FrameStream, ChannelPromise promise) booleanHttp2PromisedRequestVerifier.isAuthoritative(ChannelHandlerContext ctx, Http2Headers headers) Determine if aHttp2Headersare authoritative for a particularChannelHandlerContext.private static booleanHttp2MultiplexHandler.isServer(ChannelHandlerContext ctx) protected booleanHttp2StreamFrameToHttpObjectCodec.isSsl(ChannelHandlerContext ctx) voidHttp2FrameLogger.logData(Http2FrameLogger.Direction direction, ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endStream) voidHttp2FrameLogger.logGoAway(Http2FrameLogger.Direction direction, ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData) voidHttp2FrameLogger.logHeaders(Http2FrameLogger.Direction direction, ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream) voidHttp2FrameLogger.logHeaders(Http2FrameLogger.Direction direction, ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endStream) voidHttp2FrameLogger.logPing(Http2FrameLogger.Direction direction, ChannelHandlerContext ctx, long data) voidHttp2FrameLogger.logPingAck(Http2FrameLogger.Direction direction, ChannelHandlerContext ctx, long data) voidHttp2FrameLogger.logPriority(Http2FrameLogger.Direction direction, ChannelHandlerContext ctx, int streamId, int streamDependency, short weight, boolean exclusive) voidHttp2FrameLogger.logPushPromise(Http2FrameLogger.Direction direction, ChannelHandlerContext ctx, int streamId, int promisedStreamId, Http2Headers headers, int padding) voidHttp2FrameLogger.logRstStream(Http2FrameLogger.Direction direction, ChannelHandlerContext ctx, int streamId, long errorCode) voidHttp2FrameLogger.logSettings(Http2FrameLogger.Direction direction, ChannelHandlerContext ctx, Http2Settings settings) voidHttp2FrameLogger.logSettingsAck(Http2FrameLogger.Direction direction, ChannelHandlerContext ctx) voidHttp2FrameLogger.logUnknownFrame(Http2FrameLogger.Direction direction, ChannelHandlerContext ctx, byte frameType, int streamId, Http2Flags flags, ByteBuf data) voidHttp2FrameLogger.logWindowsUpdate(Http2FrameLogger.Direction direction, ChannelHandlerContext ctx, int streamId, int windowSizeIncrement) booleanDefaultHttp2ConnectionEncoder.FlowControlledData.merge(ChannelHandlerContext ctx, Http2RemoteFlowController.FlowControlled next) booleanDefaultHttp2ConnectionEncoder.FlowControlledHeaders.merge(ChannelHandlerContext ctx, Http2RemoteFlowController.FlowControlled next) booleanHttp2RemoteFlowController.FlowControlled.merge(ChannelHandlerContext ctx, Http2RemoteFlowController.FlowControlled next) Merge the contents of thenextmessage into this message so they can be written out as one unit.private ChannelFutureListenerHttp2ConnectionHandler.newClosingChannelFutureListener(ChannelHandlerContext ctx, ChannelPromise promise) private EmbeddedChannelCompressorHttp2ConnectionEncoder.newCompressionChannel(ChannelHandlerContext ctx, ZlibWrapper wrapper) Generate a new instance of anEmbeddedChannelcapable of compressing dataprivate EmbeddedChannelCompressorHttp2ConnectionEncoder.newCompressor(ChannelHandlerContext ctx, Http2Headers headers, boolean endOfStream) Checks if a new compressor object is needed for the stream identified bystreamId.protected EmbeddedChannelCompressorHttp2ConnectionEncoder.newContentCompressor(ChannelHandlerContext ctx, CharSequence contentEncoding) Returns a newEmbeddedChannelthat encodes the HTTP2 message content encoded in the specifiedcontentEncoding.protected EmbeddedChannelDelegatingDecompressorFrameListener.newContentDecompressor(ChannelHandlerContext ctx, CharSequence contentEncoding) Returns a newEmbeddedChannelthat decodes the HTTP2 message content encoded in the specifiedcontentEncoding.private voidDefaultHttp2ConnectionEncoder.notifyLifecycleManagerOnError(ChannelFuture future, ChannelHandlerContext ctx) protected voidHttp2ConnectionHandler.onConnectionError(ChannelHandlerContext ctx, boolean outbound, Throwable cause, Http2Exception http2Ex) Handler for a connection error.protected voidHttp2FrameCodec.onConnectionError(ChannelHandlerContext ctx, boolean outbound, Throwable cause, Http2Exception http2Ex) intDefaultHttp2ConnectionDecoder.FrameReadListener.onDataRead(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endOfStream) intDefaultHttp2ConnectionDecoder.PrefaceFrameListener.onDataRead(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endOfStream) intDelegatingDecompressorFrameListener.onDataRead(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endOfStream) intHttp2EmptyDataFrameListener.onDataRead(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endOfStream) intHttp2EventAdapter.onDataRead(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endOfStream) intHttp2FrameAdapter.onDataRead(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endOfStream) intHttp2FrameCodec.FrameListener.onDataRead(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endOfStream) intHttp2FrameListener.onDataRead(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endOfStream) Handles an inboundDATAframe.intHttp2FrameListenerDecorator.onDataRead(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endOfStream) intInboundHttp2ToHttpAdapter.onDataRead(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endOfStream) voidHttp2ConnectionHandler.onError(ChannelHandlerContext ctx, boolean outbound, Throwable cause) Central handler for all exceptions caught during HTTP/2 processing.voidHttp2LifecycleManager.onError(ChannelHandlerContext ctx, boolean outbound, Throwable cause) Processes the given error.voidDefaultHttp2ConnectionDecoder.FrameReadListener.onGoAwayRead(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData) voidDefaultHttp2ConnectionDecoder.PrefaceFrameListener.onGoAwayRead(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData) voidHttp2EventAdapter.onGoAwayRead(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData) voidHttp2FrameAdapter.onGoAwayRead(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData) voidHttp2FrameCodec.FrameListener.onGoAwayRead(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData) voidHttp2FrameListener.onGoAwayRead(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData) Handles an inboundGO_AWAYframe.voidHttp2FrameListenerDecorator.onGoAwayRead(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData) (package private) voidDefaultHttp2ConnectionDecoder.onGoAwayRead0(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData) voidDefaultHttp2ConnectionDecoder.FrameReadListener.onHeadersRead(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endOfStream) voidDefaultHttp2ConnectionDecoder.FrameReadListener.onHeadersRead(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endOfStream) voidDefaultHttp2ConnectionDecoder.PrefaceFrameListener.onHeadersRead(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endOfStream) voidDefaultHttp2ConnectionDecoder.PrefaceFrameListener.onHeadersRead(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endOfStream) voidDelegatingDecompressorFrameListener.onHeadersRead(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream) voidDelegatingDecompressorFrameListener.onHeadersRead(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endStream) voidHttp2EmptyDataFrameListener.onHeadersRead(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream) voidHttp2EmptyDataFrameListener.onHeadersRead(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endStream) voidHttp2EventAdapter.onHeadersRead(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream) voidHttp2EventAdapter.onHeadersRead(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endStream) voidHttp2FrameAdapter.onHeadersRead(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream) voidHttp2FrameAdapter.onHeadersRead(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endStream) voidHttp2FrameCodec.FrameListener.onHeadersRead(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endOfStream) voidHttp2FrameCodec.FrameListener.onHeadersRead(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endStream) voidHttp2FrameListener.onHeadersRead(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endOfStream) Handles an inboundHEADERSframe.voidHttp2FrameListener.onHeadersRead(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endOfStream) Handles an inboundHEADERSframe with priority information specified.voidHttp2FrameListenerDecorator.onHeadersRead(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream) voidHttp2FrameListenerDecorator.onHeadersRead(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endStream) voidInboundHttp2ToHttpAdapter.onHeadersRead(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endOfStream) voidInboundHttp2ToHttpAdapter.onHeadersRead(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endOfStream) (package private) voidHttp2FrameCodec.onHttp2Frame(ChannelHandlerContext ctx, Http2Frame frame) (package private) final voidHttp2MultiplexCodec.onHttp2Frame(ChannelHandlerContext ctx, Http2Frame frame) Deprecated.(package private) voidHttp2FrameCodec.onHttp2FrameStreamException(ChannelHandlerContext ctx, Http2FrameStreamException cause) (package private) final voidHttp2MultiplexCodec.onHttp2FrameStreamException(ChannelHandlerContext ctx, Http2FrameStreamException cause) Deprecated.private voidHttp2MultiplexCodec.onHttp2GoAwayFrame(ChannelHandlerContext ctx, Http2GoAwayFrame goAwayFrame) Deprecated.private voidHttp2MultiplexHandler.onHttp2GoAwayFrame(ChannelHandlerContext ctx, Http2GoAwayFrame goAwayFrame) (package private) voidHttp2FrameCodec.onHttp2StreamStateChanged(ChannelHandlerContext ctx, Http2FrameCodec.DefaultHttp2FrameStream stream) (package private) final voidHttp2MultiplexCodec.onHttp2StreamStateChanged(ChannelHandlerContext ctx, Http2FrameCodec.DefaultHttp2FrameStream stream) Deprecated.private voidHttp2FrameCodec.onHttp2StreamWritabilityChanged(ChannelHandlerContext ctx, Http2FrameCodec.DefaultHttp2FrameStream stream, boolean writable) private static voidHttp2FrameCodec.onHttp2UnknownStreamError(ChannelHandlerContext ctx, Throwable cause, Http2Exception.StreamException streamException) voidDefaultHttp2ConnectionDecoder.FrameReadListener.onPingAckRead(ChannelHandlerContext ctx, long data) voidDefaultHttp2ConnectionDecoder.PrefaceFrameListener.onPingAckRead(ChannelHandlerContext ctx, long data) voidHttp2EventAdapter.onPingAckRead(ChannelHandlerContext ctx, long data) voidHttp2FrameAdapter.onPingAckRead(ChannelHandlerContext ctx, long data) voidHttp2FrameCodec.FrameListener.onPingAckRead(ChannelHandlerContext ctx, long data) voidHttp2FrameListener.onPingAckRead(ChannelHandlerContext ctx, long data) Handles an inboundPINGacknowledgment.voidHttp2FrameListenerDecorator.onPingAckRead(ChannelHandlerContext ctx, long data) voidDefaultHttp2ConnectionDecoder.FrameReadListener.onPingRead(ChannelHandlerContext ctx, long data) voidDefaultHttp2ConnectionDecoder.PrefaceFrameListener.onPingRead(ChannelHandlerContext ctx, long data) voidHttp2EventAdapter.onPingRead(ChannelHandlerContext ctx, long data) voidHttp2FrameAdapter.onPingRead(ChannelHandlerContext ctx, long data) voidHttp2FrameCodec.FrameListener.onPingRead(ChannelHandlerContext ctx, long data) voidHttp2FrameListener.onPingRead(ChannelHandlerContext ctx, long data) Handles an inboundPINGframe.voidHttp2FrameListenerDecorator.onPingRead(ChannelHandlerContext ctx, long data) voidDefaultHttp2ConnectionDecoder.FrameReadListener.onPriorityRead(ChannelHandlerContext ctx, int streamId, int streamDependency, short weight, boolean exclusive) voidDefaultHttp2ConnectionDecoder.PrefaceFrameListener.onPriorityRead(ChannelHandlerContext ctx, int streamId, int streamDependency, short weight, boolean exclusive) voidHttp2EventAdapter.onPriorityRead(ChannelHandlerContext ctx, int streamId, int streamDependency, short weight, boolean exclusive) voidHttp2FrameAdapter.onPriorityRead(ChannelHandlerContext ctx, int streamId, int streamDependency, short weight, boolean exclusive) voidHttp2FrameCodec.FrameListener.onPriorityRead(ChannelHandlerContext ctx, int streamId, int streamDependency, short weight, boolean exclusive) voidHttp2FrameListener.onPriorityRead(ChannelHandlerContext ctx, int streamId, int streamDependency, short weight, boolean exclusive) Handles an inboundPRIORITYframe.voidHttp2FrameListenerDecorator.onPriorityRead(ChannelHandlerContext ctx, int streamId, int streamDependency, short weight, boolean exclusive) voidDefaultHttp2ConnectionDecoder.FrameReadListener.onPushPromiseRead(ChannelHandlerContext ctx, int streamId, int promisedStreamId, Http2Headers headers, int padding) voidDefaultHttp2ConnectionDecoder.PrefaceFrameListener.onPushPromiseRead(ChannelHandlerContext ctx, int streamId, int promisedStreamId, Http2Headers headers, int padding) voidHttp2EventAdapter.onPushPromiseRead(ChannelHandlerContext ctx, int streamId, int promisedStreamId, Http2Headers headers, int padding) voidHttp2FrameAdapter.onPushPromiseRead(ChannelHandlerContext ctx, int streamId, int promisedStreamId, Http2Headers headers, int padding) voidHttp2FrameCodec.FrameListener.onPushPromiseRead(ChannelHandlerContext ctx, int streamId, int promisedStreamId, Http2Headers headers, int padding) voidHttp2FrameListener.onPushPromiseRead(ChannelHandlerContext ctx, int streamId, int promisedStreamId, Http2Headers headers, int padding) Handles an inboundPUSH_PROMISEframe.voidHttp2FrameListenerDecorator.onPushPromiseRead(ChannelHandlerContext ctx, int streamId, int promisedStreamId, Http2Headers headers, int padding) voidInboundHttp2ToHttpAdapter.onPushPromiseRead(ChannelHandlerContext ctx, int streamId, int promisedStreamId, Http2Headers headers, int padding) voidDefaultHttp2ConnectionDecoder.FrameReadListener.onRstStreamRead(ChannelHandlerContext ctx, int streamId, long errorCode) voidDefaultHttp2ConnectionDecoder.PrefaceFrameListener.onRstStreamRead(ChannelHandlerContext ctx, int streamId, long errorCode) voidHttp2EventAdapter.onRstStreamRead(ChannelHandlerContext ctx, int streamId, long errorCode) voidHttp2FrameAdapter.onRstStreamRead(ChannelHandlerContext ctx, int streamId, long errorCode) voidHttp2FrameCodec.FrameListener.onRstStreamRead(ChannelHandlerContext ctx, int streamId, long errorCode) voidHttp2FrameListener.onRstStreamRead(ChannelHandlerContext ctx, int streamId, long errorCode) Handles an inboundRST_STREAMframe.voidHttp2FrameListenerDecorator.onRstStreamRead(ChannelHandlerContext ctx, int streamId, long errorCode) voidHttp2MaxRstFrameListener.onRstStreamRead(ChannelHandlerContext ctx, int streamId, long errorCode) voidInboundHttp2ToHttpAdapter.onRstStreamRead(ChannelHandlerContext ctx, int streamId, long errorCode) voidDefaultHttp2ConnectionDecoder.FrameReadListener.onSettingsAckRead(ChannelHandlerContext ctx) voidDefaultHttp2ConnectionDecoder.PrefaceFrameListener.onSettingsAckRead(ChannelHandlerContext ctx) voidHttp2EventAdapter.onSettingsAckRead(ChannelHandlerContext ctx) voidHttp2FrameAdapter.onSettingsAckRead(ChannelHandlerContext ctx) voidHttp2FrameCodec.FrameListener.onSettingsAckRead(ChannelHandlerContext ctx) voidHttp2FrameListener.onSettingsAckRead(ChannelHandlerContext ctx) Handles an inboundSETTINGSacknowledgment frame.voidHttp2FrameListenerDecorator.onSettingsAckRead(ChannelHandlerContext ctx) voidDefaultHttp2ConnectionDecoder.FrameReadListener.onSettingsRead(ChannelHandlerContext ctx, Http2Settings settings) voidDefaultHttp2ConnectionDecoder.PrefaceFrameListener.onSettingsRead(ChannelHandlerContext ctx, Http2Settings settings) voidHttp2EventAdapter.onSettingsRead(ChannelHandlerContext ctx, Http2Settings settings) voidHttp2FrameAdapter.onSettingsRead(ChannelHandlerContext ctx, Http2Settings settings) voidHttp2FrameCodec.FrameListener.onSettingsRead(ChannelHandlerContext ctx, Http2Settings settings) voidHttp2FrameListener.onSettingsRead(ChannelHandlerContext ctx, Http2Settings settings) Handles an inboundSETTINGSframe.voidHttp2FrameListenerDecorator.onSettingsRead(ChannelHandlerContext ctx, Http2Settings settings) voidInboundHttp2ToHttpAdapter.onSettingsRead(ChannelHandlerContext ctx, Http2Settings settings) protected voidHttp2ConnectionHandler.onStreamError(ChannelHandlerContext ctx, boolean outbound, Throwable cause, Http2Exception.StreamException http2Ex) Handler for a stream error.protected final voidHttp2FrameCodec.onStreamError(ChannelHandlerContext ctx, boolean outbound, Throwable cause, Http2Exception.StreamException streamException) Exceptions for unknown streams, that is streams that have noHttp2FrameStreamobject attached are simply logged and replied to by sending a RST_STREAM frame.voidDefaultHttp2ConnectionDecoder.FrameReadListener.onUnknownFrame(ChannelHandlerContext ctx, byte frameType, int streamId, Http2Flags flags, ByteBuf payload) voidDefaultHttp2ConnectionDecoder.PrefaceFrameListener.onUnknownFrame(ChannelHandlerContext ctx, byte frameType, int streamId, Http2Flags flags, ByteBuf payload) voidHttp2EventAdapter.onUnknownFrame(ChannelHandlerContext ctx, byte frameType, int streamId, Http2Flags flags, ByteBuf payload) voidHttp2FrameAdapter.onUnknownFrame(ChannelHandlerContext ctx, byte frameType, int streamId, Http2Flags flags, ByteBuf payload) voidHttp2FrameCodec.FrameListener.onUnknownFrame(ChannelHandlerContext ctx, byte frameType, int streamId, Http2Flags flags, ByteBuf payload) voidHttp2FrameListener.onUnknownFrame(ChannelHandlerContext ctx, byte frameType, int streamId, Http2Flags flags, ByteBuf payload) Handler for a frame not defined by the HTTP/2 spec.voidHttp2FrameListenerDecorator.onUnknownFrame(ChannelHandlerContext ctx, byte frameType, int streamId, Http2Flags flags, ByteBuf payload) private voidHttp2FrameCodec.onUpgradeEvent(ChannelHandlerContext ctx, HttpServerUpgradeHandler.UpgradeEvent evt) (package private) voidHttp2FrameCodec.onUserEventTriggered(ChannelHandlerContext ctx, Object evt) (package private) final voidHttp2MultiplexCodec.onUserEventTriggered(ChannelHandlerContext ctx, Object evt) Deprecated.voidDefaultHttp2ConnectionDecoder.FrameReadListener.onWindowUpdateRead(ChannelHandlerContext ctx, int streamId, int windowSizeIncrement) voidDefaultHttp2ConnectionDecoder.PrefaceFrameListener.onWindowUpdateRead(ChannelHandlerContext ctx, int streamId, int windowSizeIncrement) voidHttp2EventAdapter.onWindowUpdateRead(ChannelHandlerContext ctx, int streamId, int windowSizeIncrement) voidHttp2FrameAdapter.onWindowUpdateRead(ChannelHandlerContext ctx, int streamId, int windowSizeIncrement) voidHttp2FrameCodec.FrameListener.onWindowUpdateRead(ChannelHandlerContext ctx, int streamId, int windowSizeIncrement) voidHttp2FrameListener.onWindowUpdateRead(ChannelHandlerContext ctx, int streamId, int windowSizeIncrement) Handles an inboundWINDOW_UPDATEframe.voidHttp2FrameListenerDecorator.onWindowUpdateRead(ChannelHandlerContext ctx, int streamId, int windowSizeIncrement) voidHttp2StreamChannelBootstrap.open0(ChannelHandlerContext ctx, Promise<Http2StreamChannel> promise) Deprecated.should not be used directly.booleanHttp2ServerUpgradeCodec.prepareUpgradeResponse(ChannelHandlerContext ctx, FullHttpRequest upgradeRequest, HttpHeaders headers) private static voidHttp2ConnectionHandler.processGoAwayWriteResult(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData, ChannelFuture future) protected FullHttpMessageInboundHttp2ToHttpAdapter.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 voidInboundHttp2ToHttpAdapter.processHeadersEnd(ChannelHandlerContext ctx, Http2Stream stream, FullHttpMessage msg, boolean endOfStream) After HTTP/2 headers have been processed byInboundHttp2ToHttpAdapter.processHeadersBegin(ChannelHandlerContext, Http2Stream, Http2Headers, boolean, boolean, boolean)this method either sends the result up the pipeline or retains the message for future processing.private voidDefaultHttp2FrameReader.processPayloadState(ChannelHandlerContext ctx, ByteBuf in, Http2FrameListener listener) private voidHttp2ConnectionHandler.processRstStreamWriteResult(ChannelHandlerContext ctx, Http2Stream stream, ChannelFuture future) voidHttp2ConnectionHandler.read(ChannelHandlerContext ctx) Http2DataChunkedInput.readChunk(ChannelHandlerContext ctx) Deprecated.private voidDefaultHttp2FrameReader.readDataFrame(ChannelHandlerContext ctx, ByteBuf payload, Http2FrameListener listener) voidDefaultHttp2FrameReader.readFrame(ChannelHandlerContext ctx, ByteBuf input, Http2FrameListener listener) voidHttp2FrameReader.readFrame(ChannelHandlerContext ctx, ByteBuf input, Http2FrameListener listener) Attempts to read the next frame from the input buffer.voidHttp2InboundFrameLogger.readFrame(ChannelHandlerContext ctx, ByteBuf input, Http2FrameListener listener) private voidDefaultHttp2FrameReader.readGoAwayFrame(ChannelHandlerContext ctx, ByteBuf payload, Http2FrameListener listener) private voidDefaultHttp2FrameReader.readHeadersFrame(ChannelHandlerContext ctx, ByteBuf payload, Http2FrameListener listener) private voidDefaultHttp2FrameReader.readPingFrame(ChannelHandlerContext ctx, long data, Http2FrameListener listener) private voidDefaultHttp2FrameReader.readPriorityFrame(ChannelHandlerContext ctx, ByteBuf payload, Http2FrameListener listener) private voidDefaultHttp2FrameReader.readPushPromiseFrame(ChannelHandlerContext ctx, ByteBuf payload, Http2FrameListener listener) private voidDefaultHttp2FrameReader.readRstStreamFrame(ChannelHandlerContext ctx, ByteBuf payload, Http2FrameListener listener) private voidDefaultHttp2FrameReader.readSettingsFrame(ChannelHandlerContext ctx, ByteBuf payload, Http2FrameListener listener) private voidDefaultHttp2FrameReader.readUnknownFrame(ChannelHandlerContext ctx, ByteBuf payload, Http2FrameListener listener) private voidDefaultHttp2FrameReader.readWindowUpdateFrame(ChannelHandlerContext ctx, ByteBuf payload, Http2FrameListener listener) private static Http2FrameCodecHttp2ChannelDuplexHandler.requireHttp2FrameCodec(ChannelHandlerContext ctx) Http2ConnectionHandler.resetStream(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise) private ChannelFutureHttp2ConnectionHandler.resetStream(ChannelHandlerContext ctx, Http2Stream stream, long errorCode, ChannelPromise promise) Http2LifecycleManager.resetStream(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise) Ensure the stream identified bystreamIdis reset.private ChannelFutureHttp2ConnectionHandler.resetUnknownStream(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise) Sends aRST_STREAMframe even if we don't know about the stream.(package private) voidStreamBufferingEncoder.DataFrame.send(ChannelHandlerContext ctx, int streamId) (package private) abstract voidStreamBufferingEncoder.Frame.send(ChannelHandlerContext ctx, int streamId) (package private) voidStreamBufferingEncoder.HeadersFrame.send(ChannelHandlerContext ctx, int streamId) private static ChannelFutureDefaultHttp2ConnectionEncoder.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 voidHttp2ConnectionHandler.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 booleanDefaultHttp2ConnectionDecoder.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 ByteBufHttp2CodecUtil.toByteBuf(ChannelHandlerContext ctx, Throwable cause) Creates a buffer containing the error message from the given exception.private Http2HeadersHttp2StreamFrameToHttpObjectCodec.toHttp2Headers(ChannelHandlerContext ctx, HttpMessage msg) voidHttp2ClientUpgradeCodec.upgradeTo(ChannelHandlerContext ctx, FullHttpResponse upgradeResponse) voidHttp2ServerUpgradeCodec.upgradeTo(ChannelHandlerContext ctx, FullHttpRequest upgradeRequest) final voidHttp2FrameCodec.userEventTriggered(ChannelHandlerContext ctx, Object evt) Handles the cleartext HTTP upgrade event.voidHttp2MultiplexHandler.userEventTriggered(ChannelHandlerContext ctx, Object evt) voidDefaultHttp2ConnectionEncoder.FlowControlledData.write(ChannelHandlerContext ctx, int allowedBytes) voidDefaultHttp2ConnectionEncoder.FlowControlledHeaders.write(ChannelHandlerContext ctx, int allowedBytes) voidHttp2ConnectionHandler.write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) voidHttp2FrameCodec.write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) Processes allHttp2Frames.voidHttp2RemoteFlowController.FlowControlled.write(ChannelHandlerContext ctx, int allowedBytes) Writes up toallowedBytesof the encapsulated payload to the stream.voidHttpToHttp2ConnectionHandler.write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) Handles conversion ofHttpMessageandHttpContentto HTTP/2 frames.protected ChannelFutureAbstractHttp2StreamChannel.write0(ChannelHandlerContext ctx, Object msg) protected ChannelFutureHttp2MultiplexCodec.Http2MultiplexCodecStreamChannel.write0(ChannelHandlerContext ctx, Object msg) private ChannelFutureDefaultHttp2FrameWriter.writeContinuationFrames(ChannelHandlerContext ctx, int streamId, ByteBuf headerBlock, Http2CodecUtil.SimpleChannelPromiseAggregator promiseAggregator) Writes as many continuation frames as needed untilpaddingandheaderBlockare 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 aDATAframe 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 internalHttp2FrameWriterwithout 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 voidHttp2FrameCodec.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 voidHttpToHttp2ConnectionHandler.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 ChannelFutureDefaultHttp2ConnectionEncoder.writeHeaders0(ChannelHandlerContext ctx, int streamId, Http2Headers headers, boolean hasPriority, int streamDependency, short weight, boolean exclusive, int padding, boolean endOfStream, ChannelPromise promise) private ChannelFutureStreamBufferingEncoder.writeHeaders0(ChannelHandlerContext ctx, int streamId, Http2Headers headers, boolean hasPriority, int streamDependency, short weight, boolean exclusive, int padding, boolean endOfStream, ChannelPromise promise) private voidHttp2FrameCodec.writeHeadersFrame(ChannelHandlerContext ctx, Http2HeadersFrame headersFrame, ChannelPromise promise) private ChannelFutureDefaultHttp2FrameWriter.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 voidHttp2FrameCodec.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.Http2MaxRstFrameLimitEncoder.writeRstStream(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise) 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) StreamBufferingEncoder.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 voidJsonObjectDecoder.decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) protected ByteBufJsonObjectDecoder.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 voidAbstractMemcacheObjectEncoder.encode(ChannelHandlerContext ctx, Object msg, List<Object> out) protected abstract ByteBufAbstractMemcacheObjectEncoder.encodeMessage(ChannelHandlerContext ctx, M msg) Take the givenMemcacheMessageand 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 TypeMethodDescriptionvoidAbstractBinaryMemcacheDecoder.channelInactive(ChannelHandlerContext ctx) When the channel goes inactive, release all frames to prevent data leaks.voidBinaryMemcacheClientCodec.Decoder.channelInactive(ChannelHandlerContext ctx) protected voidAbstractBinaryMemcacheDecoder.decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) protected voidBinaryMemcacheClientCodec.Decoder.decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) protected voidBinaryMemcacheClientCodec.Encoder.encode(ChannelHandlerContext ctx, Object msg, List<Object> out) protected ByteBufAbstractBinaryMemcacheEncoder.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 voidMqttDecoder.decode(ChannelHandlerContext ctx, ByteBuf buffer, List<Object> out) private MqttConnAckVariableHeaderMqttDecoder.decodeConnAckVariableHeader(ChannelHandlerContext ctx, ByteBuf buffer) private MqttConnectVariableHeaderMqttDecoder.decodeConnectionVariableHeader(ChannelHandlerContext ctx, ByteBuf buffer) private static MqttFixedHeaderMqttDecoder.decodeFixedHeader(ChannelHandlerContext ctx, ByteBuf buffer) Decodes the fixed header.MqttDecoder.decodeMessageIdAndPropertiesVariableHeader(ChannelHandlerContext ctx, ByteBuf buffer) private ObjectMqttDecoder.decodePayload(ChannelHandlerContext ctx, ByteBuf buffer, MqttMessageType messageType, int maxClientIdLength, Object variableHeader) Decodes the payload.private MqttPublishVariableHeaderMqttDecoder.decodePublishVariableHeader(ChannelHandlerContext ctx, ByteBuf buffer, MqttFixedHeader mqttFixedHeader) private MqttUnsubAckPayloadMqttDecoder.decodeUnsubAckPayload(ChannelHandlerContext ctx, ByteBuf buffer) private ObjectMqttDecoder.decodeVariableHeader(ChannelHandlerContext ctx, ByteBuf buffer, MqttFixedHeader mqttFixedHeader) Decodes the variable header (if any)(package private) static ByteBufMqttEncoder.doEncode(ChannelHandlerContext ctx, MqttMessage message) This is the main encoding method.protected voidMqttEncoder.encode(ChannelHandlerContext ctx, MqttMessage msg, List<Object> out) private static ByteBufMqttEncoder.encodeConnAckMessage(ChannelHandlerContext ctx, MqttConnAckMessage message) private static ByteBufMqttEncoder.encodeConnectMessage(ChannelHandlerContext ctx, MqttConnectMessage message) private static ByteBufMqttEncoder.encodePublishMessage(ChannelHandlerContext ctx, MqttPublishMessage message) private static ByteBufMqttEncoder.encodePubReplyMessage(ChannelHandlerContext ctx, MqttMessage message) private static ByteBufMqttEncoder.encodeReasonCodePlusPropertiesMessage(ChannelHandlerContext ctx, MqttMessage message) private static ByteBufMqttEncoder.encodeSubAckMessage(ChannelHandlerContext ctx, MqttSubAckMessage message) private static ByteBufMqttEncoder.encodeSubscribeMessage(ChannelHandlerContext ctx, MqttSubscribeMessage message) private static ByteBufMqttEncoder.encodeUnsubAckMessage(ChannelHandlerContext ctx, MqttUnsubAckMessage message) private static ByteBufMqttEncoder.encodeUnsubscribeMessage(ChannelHandlerContext ctx, MqttUnsubscribeMessage message) (package private) static MqttVersionMqttCodecUtil.getMqttVersion(ChannelHandlerContext ctx) (package private) static voidMqttCodecUtil.setMqttVersion(ChannelHandlerContext ctx, MqttVersion version) (package private) static MqttFixedHeaderMqttCodecUtil.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 voidRedisArrayAggregator.decode(ChannelHandlerContext ctx, RedisMessage msg, List<Object> out) protected voidRedisDecoder.decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) protected voidRedisEncoder.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 voidSctpInboundByteStreamHandler.decode(ChannelHandlerContext ctx, SctpMessage msg, List<Object> out) protected voidSctpMessageCompletionHandler.decode(ChannelHandlerContext ctx, SctpMessage msg, List<Object> out) protected voidSctpOutboundByteStreamHandler.encode(ChannelHandlerContext ctx, ByteBuf msg, List<Object> out) voidSctpMessageCompletionHandler.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 ObjectObjectDecoder.decode(ChannelHandlerContext ctx, ByteBuf in) Deprecated.protected voidCompatibleObjectEncoder.encode(ChannelHandlerContext ctx, Serializable msg, ByteBuf out) Deprecated.protected voidObjectEncoder.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 SmtpResponseSmtpResponseDecoder.decode(ChannelHandlerContext ctx, ByteBuf buffer) protected voidSmtpRequestEncoder.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 voidSocksAuthRequestDecoder.decode(ChannelHandlerContext ctx, ByteBuf byteBuf, List<Object> out) protected voidSocksAuthResponseDecoder.decode(ChannelHandlerContext channelHandlerContext, ByteBuf byteBuf, List<Object> out) protected voidSocksCmdRequestDecoder.decode(ChannelHandlerContext ctx, ByteBuf byteBuf, List<Object> out) protected voidSocksCmdResponseDecoder.decode(ChannelHandlerContext ctx, ByteBuf byteBuf, List<Object> out) protected voidSocksInitRequestDecoder.decode(ChannelHandlerContext ctx, ByteBuf byteBuf, List<Object> out) protected voidSocksInitResponseDecoder.decode(ChannelHandlerContext ctx, ByteBuf byteBuf, List<Object> out) protected voidSocksMessageEncoder.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 voidSocksPortUnificationServerHandler.decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) private static voidSocksPortUnificationServerHandler.logKnownVersion(ChannelHandlerContext ctx, SocksVersion version) private static voidSocksPortUnificationServerHandler.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 voidSocks4ClientDecoder.decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) protected voidSocks4ServerDecoder.decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) protected voidSocks4ClientEncoder.encode(ChannelHandlerContext ctx, Socks4CommandRequest msg, ByteBuf out) protected voidSocks4ServerEncoder.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 voidSocks5CommandRequestDecoder.decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) protected voidSocks5CommandResponseDecoder.decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) protected voidSocks5InitialRequestDecoder.decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) protected voidSocks5InitialResponseDecoder.decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) protected voidSocks5PasswordAuthRequestDecoder.decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) protected voidSocks5PasswordAuthResponseDecoder.decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) protected voidSocks5ClientEncoder.encode(ChannelHandlerContext ctx, Socks5Message msg, ByteBuf out) protected voidSocks5ServerEncoder.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 ChannelHandlerContextSpdyFrameCodec.ctxprivate final ChannelHandlerContextSpdySessionHandler.ClosingChannelFutureListener.ctxMethods in io.netty.handler.codec.spdy with parameters of type ChannelHandlerContextModifier and TypeMethodDescriptionvoidSpdyFrameCodec.bind(ChannelHandlerContext ctx, SocketAddress localAddress, ChannelPromise promise) voidSpdyHttpDecoder.channelInactive(ChannelHandlerContext ctx) voidSpdySessionHandler.channelInactive(ChannelHandlerContext ctx) voidSpdySessionHandler.channelRead(ChannelHandlerContext ctx, Object msg) voidSpdyFrameCodec.channelReadComplete(ChannelHandlerContext ctx) voidSpdyFrameCodec.close(ChannelHandlerContext ctx, ChannelPromise promise) voidSpdySessionHandler.close(ChannelHandlerContext ctx, ChannelPromise promise) voidSpdyFrameCodec.connect(ChannelHandlerContext ctx, SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) protected voidSpdyFrameCodec.decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) protected voidSpdyHttpDecoder.decode(ChannelHandlerContext ctx, SpdyFrame msg, List<Object> out) protected voidSpdyHttpResponseStreamIdHandler.decode(ChannelHandlerContext ctx, Object msg, List<Object> out) voidSpdyFrameCodec.deregister(ChannelHandlerContext ctx, ChannelPromise promise) voidSpdyFrameCodec.disconnect(ChannelHandlerContext ctx, ChannelPromise promise) protected voidSpdyHttpEncoder.encode(ChannelHandlerContext ctx, HttpObject msg, List<Object> out) protected voidSpdyHttpResponseStreamIdHandler.encode(ChannelHandlerContext ctx, HttpMessage msg, List<Object> out) voidSpdySessionHandler.exceptionCaught(ChannelHandlerContext ctx, Throwable cause) voidSpdyFrameCodec.flush(ChannelHandlerContext ctx) private voidSpdySessionHandler.handleOutboundMessage(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) voidSpdyFrameCodec.handlerAdded(ChannelHandlerContext ctx) private voidSpdySessionHandler.issueSessionError(ChannelHandlerContext ctx, SpdySessionStatus status) private voidSpdySessionHandler.issueStreamError(ChannelHandlerContext ctx, int streamId, SpdyStreamStatus status) voidSpdyFrameCodec.read(ChannelHandlerContext ctx) private voidSpdySessionHandler.sendGoAwayFrame(ChannelHandlerContext ctx, ChannelPromise future) private ChannelFutureSpdySessionHandler.sendGoAwayFrame(ChannelHandlerContext ctx, SpdySessionStatus status) private voidSpdySessionHandler.updateSendWindowSize(ChannelHandlerContext ctx, int streamId, int deltaWindowSize) voidSpdyFrameCodec.write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) voidSpdySessionHandler.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 voidStompSubframeDecoder.decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) protected voidStompSubframeEncoder.encode(ChannelHandlerContext ctx, StompSubframe msg, List<Object> out) private static ByteBufStompSubframeEncoder.encodeContent(StompContentSubframe content, ChannelHandlerContext ctx) private ByteBufStompSubframeEncoder.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 voidStringDecoder.decode(ChannelHandlerContext ctx, ByteBuf msg, List<Object> out) protected voidLineEncoder.encode(ChannelHandlerContext ctx, CharSequence msg, List<Object> out) protected voidStringEncoder.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 voidXmlDecoder.decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) protected voidXmlFrameDecoder.decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) private static voidXmlFrameDecoder.fail(ChannelHandlerContext ctx) -
Uses of ChannelHandlerContext in io.netty.handler.flow
Methods in io.netty.handler.flow with parameters of type ChannelHandlerContextModifier and TypeMethodDescriptionvoidFlowControlHandler.channelInactive(ChannelHandlerContext ctx) voidFlowControlHandler.channelRead(ChannelHandlerContext ctx, Object msg) voidFlowControlHandler.channelReadComplete(ChannelHandlerContext ctx) private intFlowControlHandler.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.voidFlowControlHandler.handlerAdded(ChannelHandlerContext ctx) voidFlowControlHandler.handlerRemoved(ChannelHandlerContext ctx) voidFlowControlHandler.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 TypeMethodDescriptionvoidFlushConsolidationHandler.channelRead(ChannelHandlerContext ctx, Object msg) voidFlushConsolidationHandler.channelReadComplete(ChannelHandlerContext ctx) voidFlushConsolidationHandler.channelWritabilityChanged(ChannelHandlerContext ctx) voidFlushConsolidationHandler.close(ChannelHandlerContext ctx, ChannelPromise promise) voidFlushConsolidationHandler.disconnect(ChannelHandlerContext ctx, ChannelPromise promise) voidFlushConsolidationHandler.exceptionCaught(ChannelHandlerContext ctx, Throwable cause) voidFlushConsolidationHandler.flush(ChannelHandlerContext ctx) private voidFlushConsolidationHandler.flushIfNeeded(ChannelHandlerContext ctx) private voidFlushConsolidationHandler.flushNow(ChannelHandlerContext ctx) voidFlushConsolidationHandler.handlerAdded(ChannelHandlerContext ctx) voidFlushConsolidationHandler.handlerRemoved(ChannelHandlerContext ctx) private voidFlushConsolidationHandler.resetReadAndFlushIfNeeded(ChannelHandlerContext ctx) private voidFlushConsolidationHandler.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 booleanAbstractRemoteAddressFilter.accept(ChannelHandlerContext ctx, T remoteAddress) This method is called immediately after aChannelgets registered.protected booleanIpSubnetFilter.accept(ChannelHandlerContext ctx, InetSocketAddress remoteAddress) protected booleanRuleBasedIpFilter.accept(ChannelHandlerContext ctx, InetSocketAddress remoteAddress) protected booleanUniqueIpFilter.accept(ChannelHandlerContext ctx, InetSocketAddress remoteAddress) protected voidAbstractRemoteAddressFilter.channelAccepted(ChannelHandlerContext ctx, T remoteAddress) This method is called ifremoteAddressgets accepted byAbstractRemoteAddressFilter.accept(ChannelHandlerContext, SocketAddress).voidAbstractRemoteAddressFilter.channelActive(ChannelHandlerContext ctx) voidAbstractRemoteAddressFilter.channelRegistered(ChannelHandlerContext ctx) protected ChannelFutureAbstractRemoteAddressFilter.channelRejected(ChannelHandlerContext ctx, T remoteAddress) This method is called ifremoteAddressgets rejected byAbstractRemoteAddressFilter.accept(ChannelHandlerContext, SocketAddress).private booleanAbstractRemoteAddressFilter.handleNewChannel(ChannelHandlerContext ctx) -
Uses of ChannelHandlerContext in io.netty.handler.logging
Methods in io.netty.handler.logging with parameters of type ChannelHandlerContextModifier and TypeMethodDescriptionvoidLoggingHandler.bind(ChannelHandlerContext ctx, SocketAddress localAddress, ChannelPromise promise) voidLoggingHandler.channelActive(ChannelHandlerContext ctx) voidLoggingHandler.channelInactive(ChannelHandlerContext ctx) voidLoggingHandler.channelRead(ChannelHandlerContext ctx, Object msg) voidLoggingHandler.channelReadComplete(ChannelHandlerContext ctx) voidLoggingHandler.channelRegistered(ChannelHandlerContext ctx) voidLoggingHandler.channelUnregistered(ChannelHandlerContext ctx) voidLoggingHandler.channelWritabilityChanged(ChannelHandlerContext ctx) voidLoggingHandler.close(ChannelHandlerContext ctx, ChannelPromise promise) voidLoggingHandler.connect(ChannelHandlerContext ctx, SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) voidLoggingHandler.deregister(ChannelHandlerContext ctx, ChannelPromise promise) voidLoggingHandler.disconnect(ChannelHandlerContext ctx, ChannelPromise promise) voidLoggingHandler.exceptionCaught(ChannelHandlerContext ctx, Throwable cause) voidLoggingHandler.flush(ChannelHandlerContext ctx) protected StringLoggingHandler.format(ChannelHandlerContext ctx, String eventName) Formats an event and returns the formatted message.protected StringLoggingHandler.format(ChannelHandlerContext ctx, String eventName, Object arg) Formats an event and returns the formatted message.protected StringLoggingHandler.format(ChannelHandlerContext ctx, String eventName, Object firstArg, Object secondArg) Formats an event and returns the formatted message.private StringLoggingHandler.formatByteBuf(ChannelHandlerContext ctx, String eventName, ByteBuf msg) Generates the default log message of the specified event whose argument is aByteBuf.private StringLoggingHandler.formatByteBufHolder(ChannelHandlerContext ctx, String eventName, ByteBufHolder msg) Generates the default log message of the specified event whose argument is aByteBufHolder.private static StringLoggingHandler.formatSimple(ChannelHandlerContext ctx, String eventName, Object msg) Generates the default log message of the specified event whose argument is an arbitrary object.voidLoggingHandler.userEventTriggered(ChannelHandlerContext ctx, Object evt) voidLoggingHandler.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 TypeMethodDescriptionvoidPcapWriteHandler.channelActive(ChannelHandlerContext ctx) voidPcapWriteHandler.channelRead(ChannelHandlerContext ctx, Object msg) private voidPcapWriteHandler.completeTCPWrite(InetSocketAddress srcAddr, InetSocketAddress dstAddr, ByteBuf tcpBuf, ByteBufAllocator byteBufAllocator, ChannelHandlerContext ctx) Write TCP/IP L3 and L2 here.private voidPcapWriteHandler.completeUDPWrite(InetSocketAddress srcAddr, InetSocketAddress dstAddr, ByteBuf udpBuf, ByteBufAllocator byteBufAllocator, ChannelHandlerContext ctx) Write UDP/IP L3 and L2 here.voidPcapWriteHandler.exceptionCaught(ChannelHandlerContext ctx, Throwable cause) voidPcapWriteHandler.handlerRemoved(ChannelHandlerContext ctx) private voidPcapWriteHandler.handleTCP(ChannelHandlerContext ctx, Object msg, boolean isWriteOperation) Handle TCP L4private voidPcapWriteHandler.handleTcpPacket(ChannelHandlerContext ctx, ByteBuf packet, boolean isWriteOperation, ByteBufAllocator byteBufAllocator) private voidPcapWriteHandler.handleUDP(ChannelHandlerContext ctx, Object msg, boolean isWriteOperation) Handle UDP l4private voidPcapWriteHandler.initializeIfNecessary(ChannelHandlerContext ctx) voidPcapWriteHandler.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 voidHttpProxyHandler.addCodec(ChannelHandlerContext ctx) protected abstract voidProxyHandler.addCodec(ChannelHandlerContext ctx) Adds the codec handlers required to communicate with the proxy server.protected voidSocks4ProxyHandler.addCodec(ChannelHandlerContext ctx) protected voidSocks5ProxyHandler.addCodec(ChannelHandlerContext ctx) private voidProxyHandler.addPendingWrite(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) voidHttpProxyHandler.HttpClientCodecWrapper.bind(ChannelHandlerContext ctx, SocketAddress localAddress, ChannelPromise promise) voidHttpProxyHandler.HttpClientCodecWrapper.channelActive(ChannelHandlerContext ctx) final voidProxyHandler.channelActive(ChannelHandlerContext ctx) voidHttpProxyHandler.HttpClientCodecWrapper.channelInactive(ChannelHandlerContext ctx) final voidProxyHandler.channelInactive(ChannelHandlerContext ctx) voidHttpProxyHandler.HttpClientCodecWrapper.channelRead(ChannelHandlerContext ctx, Object msg) final voidProxyHandler.channelRead(ChannelHandlerContext ctx, Object msg) voidHttpProxyHandler.HttpClientCodecWrapper.channelReadComplete(ChannelHandlerContext ctx) final voidProxyHandler.channelReadComplete(ChannelHandlerContext ctx) voidHttpProxyHandler.HttpClientCodecWrapper.channelRegistered(ChannelHandlerContext ctx) voidHttpProxyHandler.HttpClientCodecWrapper.channelUnregistered(ChannelHandlerContext ctx) voidHttpProxyHandler.HttpClientCodecWrapper.channelWritabilityChanged(ChannelHandlerContext ctx) voidHttpProxyHandler.HttpClientCodecWrapper.close(ChannelHandlerContext ctx, ChannelPromise promise) voidHttpProxyHandler.HttpClientCodecWrapper.connect(ChannelHandlerContext ctx, SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) final voidProxyHandler.connect(ChannelHandlerContext ctx, SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) voidHttpProxyHandler.HttpClientCodecWrapper.deregister(ChannelHandlerContext ctx, ChannelPromise promise) voidHttpProxyHandler.HttpClientCodecWrapper.disconnect(ChannelHandlerContext ctx, ChannelPromise promise) voidHttpProxyHandler.HttpClientCodecWrapper.exceptionCaught(ChannelHandlerContext ctx, Throwable cause) final voidProxyHandler.exceptionCaught(ChannelHandlerContext ctx, Throwable cause) voidHttpProxyHandler.HttpClientCodecWrapper.flush(ChannelHandlerContext ctx) final voidProxyHandler.flush(ChannelHandlerContext ctx) voidHttpProxyHandler.HttpClientCodecWrapper.handlerAdded(ChannelHandlerContext ctx) final voidProxyHandler.handlerAdded(ChannelHandlerContext ctx) protected booleanHttpProxyHandler.handleResponse(ChannelHandlerContext ctx, Object response) protected abstract booleanProxyHandler.handleResponse(ChannelHandlerContext ctx, Object response) Handles the message received from the proxy server.protected booleanSocks4ProxyHandler.handleResponse(ChannelHandlerContext ctx, Object response) protected booleanSocks5ProxyHandler.handleResponse(ChannelHandlerContext ctx, Object response) voidHttpProxyHandler.HttpClientCodecWrapper.handlerRemoved(ChannelHandlerContext ctx) protected ObjectHttpProxyHandler.newInitialMessage(ChannelHandlerContext ctx) protected abstract ObjectProxyHandler.newInitialMessage(ChannelHandlerContext ctx) Returns a new message that is sent at first time when the connection to the proxy server has been established.protected ObjectSocks4ProxyHandler.newInitialMessage(ChannelHandlerContext ctx) protected ObjectSocks5ProxyHandler.newInitialMessage(ChannelHandlerContext ctx) voidHttpProxyHandler.HttpClientCodecWrapper.read(ChannelHandlerContext ctx) private static voidProxyHandler.readIfNeeded(ChannelHandlerContext ctx) protected voidHttpProxyHandler.removeDecoder(ChannelHandlerContext ctx) protected abstract voidProxyHandler.removeDecoder(ChannelHandlerContext ctx) Removes the decoders added inProxyHandler.addCodec(ChannelHandlerContext).protected voidSocks4ProxyHandler.removeDecoder(ChannelHandlerContext ctx) protected voidSocks5ProxyHandler.removeDecoder(ChannelHandlerContext ctx) protected voidHttpProxyHandler.removeEncoder(ChannelHandlerContext ctx) protected abstract voidProxyHandler.removeEncoder(ChannelHandlerContext ctx) Removes the encoders added inProxyHandler.addCodec(ChannelHandlerContext).protected voidSocks4ProxyHandler.removeEncoder(ChannelHandlerContext ctx) protected voidSocks5ProxyHandler.removeEncoder(ChannelHandlerContext ctx) private voidSocks5ProxyHandler.sendConnectCommand(ChannelHandlerContext ctx) private voidProxyHandler.sendInitialMessage(ChannelHandlerContext ctx) Sends the initial message to be sent to the proxy server.voidHttpProxyHandler.HttpClientCodecWrapper.userEventTriggered(ChannelHandlerContext ctx, Object evt) voidHttpProxyHandler.HttpClientCodecWrapper.write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) final voidProxyHandler.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 ChannelHandlerContextApplicationProtocolNegotiationHandler.ctxprivate ChannelHandlerContextSslHandler.ctxMethods in io.netty.handler.ssl with parameters of type ChannelHandlerContextModifier and TypeMethodDescriptionprivate ByteBufSslHandler.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 ByteBufSslHandler.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.voidSslClientHelloHandler.bind(ChannelHandlerContext ctx, SocketAddress localAddress, ChannelPromise promise) voidSslHandler.bind(ChannelHandlerContext ctx, SocketAddress localAddress, ChannelPromise promise) voidAbstractSniHandler.channelActive(ChannelHandlerContext ctx) voidSslHandler.channelActive(ChannelHandlerContext ctx) Issues an initial TLS handshake once connected when used in client-modevoidApplicationProtocolNegotiationHandler.channelInactive(ChannelHandlerContext ctx) voidSslHandler.channelInactive(ChannelHandlerContext ctx) voidApplicationProtocolNegotiationHandler.channelRead(ChannelHandlerContext ctx, Object msg) voidSslHandler.channelReadComplete(ChannelHandlerContext ctx) private voidSslHandler.channelReadComplete0(ChannelHandlerContext ctx) private voidAbstractSniHandler.checkStartTimeout(ChannelHandlerContext ctx) voidSslClientHelloHandler.close(ChannelHandlerContext ctx, ChannelPromise promise) voidSslHandler.close(ChannelHandlerContext ctx, ChannelPromise promise) private voidSslHandler.closeOutboundAndChannel(ChannelHandlerContext ctx, ChannelPromise promise, boolean disconnect) protected abstract voidApplicationProtocolNegotiationHandler.configurePipeline(ChannelHandlerContext ctx, String protocol) Invoked on successful initial SSL/TLS handshake.voidSslClientHelloHandler.connect(ChannelHandlerContext ctx, SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) voidSslHandler.connect(ChannelHandlerContext ctx, SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) protected voidOptionalSslHandler.decode(ChannelHandlerContext context, ByteBuf in, List<Object> out) protected voidSslClientHelloHandler.decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) protected voidSslHandler.decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) private voidSslHandler.decodeJdkCompatible(ChannelHandlerContext ctx, ByteBuf in) private voidSslHandler.decodeNonJdkCompatible(ChannelHandlerContext ctx, ByteBuf in) voidSslClientHelloHandler.deregister(ChannelHandlerContext ctx, ChannelPromise promise) voidSslHandler.deregister(ChannelHandlerContext ctx, ChannelPromise promise) voidSslClientHelloHandler.disconnect(ChannelHandlerContext ctx, ChannelPromise promise) voidSslHandler.disconnect(ChannelHandlerContext ctx, ChannelPromise promise) voidApplicationProtocolNegotiationHandler.exceptionCaught(ChannelHandlerContext ctx, Throwable cause) voidSslHandler.exceptionCaught(ChannelHandlerContext ctx, Throwable cause) private voidSslHandler.executeChannelRead(ChannelHandlerContext ctx, ByteBuf decodedOut) private voidSslHandler.executeNotifyClosePromise(ChannelHandlerContext ctx) private static voidAbstractSniHandler.fireSniCompletionEvent(ChannelHandlerContext ctx, String hostname, Future<?> future) voidSslClientHelloHandler.flush(ChannelHandlerContext ctx) voidSslHandler.flush(ChannelHandlerContext ctx) private voidSslHandler.flush(ChannelHandlerContext ctx, ChannelPromise promise) private voidSslHandler.flushIfNeeded(ChannelHandlerContext ctx) private voidSslHandler.forceFlush(ChannelHandlerContext ctx) (package private) static voidSslUtils.handleHandshakeFailure(ChannelHandlerContext ctx, Throwable cause, boolean notify) private voidOptionalSslHandler.handleNonSsl(ChannelHandlerContext context) voidAbstractSniHandler.handlerAdded(ChannelHandlerContext ctx) voidApplicationProtocolNegotiationHandler.handlerAdded(ChannelHandlerContext ctx) voidSslHandler.handlerAdded(ChannelHandlerContext ctx) voidApplicationProtocolNegotiationHandler.handlerRemoved(ChannelHandlerContext ctx) protected voidSslClientHelloHandler.handlerRemoved0(ChannelHandlerContext ctx) voidSslHandler.handlerRemoved0(ChannelHandlerContext ctx) private voidOptionalSslHandler.handleSsl(ChannelHandlerContext context) private voidSslHandler.handleUnwrapThrowable(ChannelHandlerContext ctx, Throwable cause) protected voidApplicationProtocolNegotiationHandler.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 aFuturewhich 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 givenClientHelloand returns aFuturewhich in turn will notify theSslClientHelloHandler.onLookupComplete(ChannelHandlerContext, Future)on completion.protected ChannelHandlerOptionalSslHandler.newNonSslHandler(ChannelHandlerContext context) Override to configure the ChannelHandler.protected SslHandlerOptionalSslHandler.newSslHandler(ChannelHandlerContext context, SslContext sslContext) Override to configure the SslHandler eg.protected voidAbstractSniHandler.onLookupComplete(ChannelHandlerContext ctx, Future<T> future) protected abstract voidAbstractSniHandler.onLookupComplete(ChannelHandlerContext ctx, String hostname, Future<T> future) Called upon completion of theAbstractSniHandler.lookup(ChannelHandlerContext, String)Future.protected final voidSniHandler.onLookupComplete(ChannelHandlerContext ctx, String hostname, Future<SslContext> future) protected abstract voidSslClientHelloHandler.onLookupComplete(ChannelHandlerContext ctx, Future<T> future) Called upon completion of theSslClientHelloHandler.lookup(ChannelHandlerContext, ByteBuf)Future.voidSslClientHelloHandler.read(ChannelHandlerContext ctx) voidSslHandler.read(ChannelHandlerContext ctx) private voidSslHandler.readIfNeeded(ChannelHandlerContext ctx) private voidSslHandler.releaseAndFailAll(ChannelHandlerContext ctx, Throwable cause) private voidApplicationProtocolNegotiationHandler.removeSelfIfPresent(ChannelHandlerContext ctx) protected voidSniHandler.replaceHandler(ChannelHandlerContext ctx, String hostname, SslContext sslContext) The default implementation of this method will simply replacethisSniHandlerinstance with aSslHandler.private voidSslHandler.safeClose(ChannelHandlerContext ctx, ChannelFuture flushFuture, ChannelPromise promise) private voidSslClientHelloHandler.select(ChannelHandlerContext ctx, ByteBuf clientHello) private voidSslHandler.setHandshakeFailure(ChannelHandlerContext ctx, Throwable cause) Notify all the handshake futures about the failure during the handshake.private voidSslHandler.setHandshakeFailure(ChannelHandlerContext ctx, Throwable cause, boolean closeInbound, boolean notify, boolean alwaysFlushAndClose) Notify all the handshake futures about the failure during the handshake.private voidSslHandler.setHandshakeFailureTransportFailure(ChannelHandlerContext ctx, Throwable cause) private intSslHandler.unwrap(ChannelHandlerContext ctx, ByteBuf packet, int length) Unwraps inbound SSL records.private intSslHandler.unwrapNonAppData(ChannelHandlerContext ctx) CallsSSLEngine.unwrap(ByteBuffer, ByteBuffer)with an empty buffer to handle handshakes, etc.voidApplicationProtocolNegotiationHandler.userEventTriggered(ChannelHandlerContext ctx, Object evt) final voidSslMasterKeyHandler.userEventTriggered(ChannelHandlerContext ctx, Object evt) private voidSslHandler.wrap(ChannelHandlerContext ctx, boolean inUnwrap) private voidSslHandler.wrapAndFlush(ChannelHandlerContext ctx) private booleanSslHandler.wrapNonAppData(ChannelHandlerContext ctx, boolean inUnwrap) voidSslClientHelloHandler.write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) voidSslHandler.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 voidOcspHttpHandler.channelRead0(ChannelHandlerContext ctx, FullHttpResponse response) voidOcspHttpHandler.exceptionCaught(ChannelHandlerContext ctx, Throwable cause) voidOcspServerCertificateValidator.exceptionCaught(ChannelHandlerContext ctx, Throwable cause) voidOcspClientHandler.userEventTriggered(ChannelHandlerContext ctx, Object evt) voidOcspServerCertificateValidator.userEventTriggered(ChannelHandlerContext ctx, Object evt) protected abstract booleanOcspClientHandler.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 TypeMethodDescriptionvoidChunkedWriteHandler.channelInactive(ChannelHandlerContext ctx) voidChunkedWriteHandler.channelWritabilityChanged(ChannelHandlerContext ctx) private voidChunkedWriteHandler.doFlush(ChannelHandlerContext ctx) voidChunkedWriteHandler.flush(ChannelHandlerContext ctx) voidChunkedWriteHandler.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 voidChunkedWriteHandler.resumeTransfer0(ChannelHandlerContext ctx) voidChunkedWriteHandler.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 ChannelHandlerContextIdleStateHandler.AbstractIdleTask.ctxprivate final ChannelHandlerContextWriteTimeoutHandler.WriteTimeoutTask.ctxMethods in io.netty.handler.timeout with parameters of type ChannelHandlerContextModifier and TypeMethodDescriptionvoidIdleStateHandler.channelActive(ChannelHandlerContext ctx) protected voidIdleStateHandler.channelIdle(ChannelHandlerContext ctx, IdleStateEvent evt) Is called when anIdleStateEventshould be fired.protected final voidReadTimeoutHandler.channelIdle(ChannelHandlerContext ctx, IdleStateEvent evt) voidIdleStateHandler.channelInactive(ChannelHandlerContext ctx) voidIdleStateHandler.channelRead(ChannelHandlerContext ctx, Object msg) voidIdleStateHandler.channelReadComplete(ChannelHandlerContext ctx) voidIdleStateHandler.channelRegistered(ChannelHandlerContext ctx) voidIdleStateHandler.handlerAdded(ChannelHandlerContext ctx) voidIdleStateHandler.handlerRemoved(ChannelHandlerContext ctx) voidWriteTimeoutHandler.handlerRemoved(ChannelHandlerContext ctx) private booleanIdleStateHandler.hasOutputChanged(ChannelHandlerContext ctx, boolean first) Returnstrueif and only if theIdleStateHandlerwas constructed withIdleStateHandler.observeOutputenabled and there has been an observed change in theChannelOutboundBufferbetween two consecutive calls of this method.private voidIdleStateHandler.initialize(ChannelHandlerContext ctx) private voidIdleStateHandler.initOutputChanged(ChannelHandlerContext ctx) protected voidReadTimeoutHandler.readTimedOut(ChannelHandlerContext ctx) Is called when a read timeout was detected.protected abstract voidIdleStateHandler.AbstractIdleTask.run(ChannelHandlerContext ctx) protected voidIdleStateHandler.AllIdleTimeoutTask.run(ChannelHandlerContext ctx) protected voidIdleStateHandler.ReaderIdleTimeoutTask.run(ChannelHandlerContext ctx) protected voidIdleStateHandler.WriterIdleTimeoutTask.run(ChannelHandlerContext ctx) (package private) Future<?> IdleStateHandler.schedule(ChannelHandlerContext ctx, Runnable task, long delay, TimeUnit unit) This method is visible for testing!private voidWriteTimeoutHandler.scheduleTimeout(ChannelHandlerContext ctx, ChannelPromise promise) voidIdleStateHandler.write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) voidWriteTimeoutHandler.write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) protected voidWriteTimeoutHandler.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 ChannelHandlerContextAbstractTrafficShapingHandler.ReopenReadTimerTask.ctxMethods in io.netty.handler.traffic with parameters of type ChannelHandlerContextModifier and TypeMethodDescriptionvoidAbstractTrafficShapingHandler.channelRead(ChannelHandlerContext ctx, Object msg) voidGlobalChannelTrafficShapingHandler.channelRead(ChannelHandlerContext ctx, Object msg) voidAbstractTrafficShapingHandler.channelRegistered(ChannelHandlerContext ctx) (package private) longAbstractTrafficShapingHandler.checkWaitReadTime(ChannelHandlerContext ctx, long wait, long now) Method overridden in GTSH to take into account specific timer for the channel.protected longGlobalChannelTrafficShapingHandler.checkWaitReadTime(ChannelHandlerContext ctx, long wait, long now) (package private) longGlobalTrafficShapingHandler.checkWaitReadTime(ChannelHandlerContext ctx, long wait, long now) (package private) voidAbstractTrafficShapingHandler.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) voidChannelTrafficShapingHandler.handlerAdded(ChannelHandlerContext ctx) voidGlobalChannelTrafficShapingHandler.handlerAdded(ChannelHandlerContext ctx) voidGlobalTrafficShapingHandler.handlerAdded(ChannelHandlerContext ctx) voidAbstractTrafficShapingHandler.handlerRemoved(ChannelHandlerContext ctx) voidChannelTrafficShapingHandler.handlerRemoved(ChannelHandlerContext ctx) voidGlobalChannelTrafficShapingHandler.handlerRemoved(ChannelHandlerContext ctx) voidGlobalTrafficShapingHandler.handlerRemoved(ChannelHandlerContext ctx) (package private) voidAbstractTrafficShapingHandler.informReadOperation(ChannelHandlerContext ctx, long now) Method overridden in GTSH to take into account specific timer for the channel.protected voidGlobalChannelTrafficShapingHandler.informReadOperation(ChannelHandlerContext ctx, long now) (package private) voidGlobalTrafficShapingHandler.informReadOperation(ChannelHandlerContext ctx, long now) protected static booleanAbstractTrafficShapingHandler.isHandlerActive(ChannelHandlerContext ctx) voidAbstractTrafficShapingHandler.read(ChannelHandlerContext ctx) (package private) voidAbstractTrafficShapingHandler.releaseReadSuspended(ChannelHandlerContext ctx) Release the Read suspension(package private) voidAbstractTrafficShapingHandler.releaseWriteSuspended(ChannelHandlerContext ctx) Explicitly release the Write suspended status.private voidChannelTrafficShapingHandler.sendAllValid(ChannelHandlerContext ctx, long now) private voidGlobalChannelTrafficShapingHandler.sendAllValid(ChannelHandlerContext ctx, GlobalChannelTrafficShapingHandler.PerChannel perChannel, long now) private voidGlobalTrafficShapingHandler.sendAllValid(ChannelHandlerContext ctx, GlobalTrafficShapingHandler.PerChannel perChannel, long now) (package private) voidAbstractTrafficShapingHandler.setUserDefinedWritability(ChannelHandlerContext ctx, boolean writable) (package private) abstract voidAbstractTrafficShapingHandler.submitWrite(ChannelHandlerContext ctx, Object msg, long size, long delay, long now, ChannelPromise promise) protected voidAbstractTrafficShapingHandler.submitWrite(ChannelHandlerContext ctx, Object msg, long delay, ChannelPromise promise) Deprecated.(package private) voidChannelTrafficShapingHandler.submitWrite(ChannelHandlerContext ctx, Object msg, long size, long delay, long now, ChannelPromise promise) protected voidGlobalChannelTrafficShapingHandler.submitWrite(ChannelHandlerContext ctx, Object msg, long size, long writedelay, long now, ChannelPromise promise) (package private) voidGlobalTrafficShapingHandler.submitWrite(ChannelHandlerContext ctx, Object msg, long size, long writedelay, long now, ChannelPromise promise) voidAbstractTrafficShapingHandler.write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) voidGlobalChannelTrafficShapingHandler.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 TypeMethodDescriptionvoidDnsNameResolver.DnsResponseHandler.channelRead(ChannelHandlerContext ctx, Object msg) voidDnsNameResolver.DnsResponseHandler.exceptionCaught(ChannelHandlerContext ctx, Throwable cause)
ChannelInboundHandlerand implement the method there.