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