Package | Description |
---|---|
io.netty.channel |
The core channel API which is asynchronous and event-driven abstraction of
various transports such as a
NIO Channel.
|
io.netty.handler.codec |
Extensible decoder and its common implementations which deal with the
packet fragmentation and reassembly issue found in a stream-based transport
such as TCP/IP.
|
io.netty.handler.codec.base64 | |
io.netty.handler.codec.bytes |
Encoder and decoder which transform an array of bytes into a
ByteBuf and vice versa. |
io.netty.handler.codec.compression | |
io.netty.handler.codec.dns |
DNS codec information for writing to and reading from a DNS server.
|
io.netty.handler.codec.haproxy |
Decodes an HAProxy proxy protocol header
|
io.netty.handler.codec.http |
Encoder, decoder and their related message types for HTTP.
|
io.netty.handler.codec.http.cors |
This package contains Cross Origin Resource Sharing (CORS) related classes.
|
io.netty.handler.codec.http.multipart |
HTTP multipart support.
|
io.netty.handler.codec.http.websocketx |
Encoder, decoder, handshakers and their related message types for
Web Socket data frames.
|
io.netty.handler.codec.http.websocketx.extensions |
Encoder, decoder, handshakers to handle
WebSocket Extensions.
|
io.netty.handler.codec.http2 |
Handlers for sending and receiving HTTP/2 frames.
|
io.netty.handler.codec.json |
JSON specific codecs.
|
io.netty.handler.codec.marshalling |
Decoder and Encoder which uses JBoss Marshalling.
|
io.netty.handler.codec.memcache |
Common superset of ascii and binary classes.
|
io.netty.handler.codec.memcache.binary |
Implementations and Interfaces for the Memcache Binary protocol.
|
io.netty.handler.codec.mqtt |
Encoder, decoder and different Message Types for MQTT.
|
io.netty.handler.codec.protobuf |
Encoder and decoder which transform a
Google Protocol Buffers
Message into a ByteBuf
and vice versa. |
io.netty.handler.codec.sctp |
Decoder and encoders to manage message completion and multi-streaming codec in SCTP/IP.
|
io.netty.handler.codec.serialization |
Encoder, decoder and their compatibility stream implementations which
transform a
Serializable object into a byte buffer and
vice versa. |
io.netty.handler.codec.socksx |
Encoder, decoder and their related message types for SOCKS protocol.
|
io.netty.handler.codec.socksx.v4 |
Encoder, decoder and their related message types for SOCKSv4 protocol.
|
io.netty.handler.codec.socksx.v5 |
Encoder, decoder and their related message types for SOCKSv5 protocol.
|
io.netty.handler.codec.spdy |
Encoder, decoder, session handler and their related message types for the SPDY protocol.
|
io.netty.handler.codec.stomp |
STOMP codec
|
io.netty.handler.codec.string | |
io.netty.handler.codec.xml |
Xml specific codecs.
|
io.netty.handler.ipfilter |
Package to filter IP addresses (allow/deny).
|
io.netty.handler.logging |
Logs the I/O events for debugging purpose.
|
io.netty.handler.proxy |
Adds support for client connections via proxy protocols such as
SOCKS and
HTTP CONNECT tunneling
|
io.netty.handler.ssl | |
io.netty.handler.stream |
Writes very large data stream asynchronously neither spending a lot of
memory nor getting
OutOfMemoryError . |
io.netty.handler.timeout |
Adds support for read and write timeout and idle connection notification
using a
Timer . |
io.netty.handler.traffic |
Implementation of a Traffic Shaping Handler and Dynamic Statistics.
|
Modifier and Type | Method and Description |
---|---|
ChannelHandlerContext |
ChannelPipeline.context(ChannelHandler handler)
Returns the context object of the specified
ChannelHandler in
this pipeline. |
ChannelHandlerContext |
ChannelPipeline.context(Class<? extends ChannelHandler> handlerType)
Returns the context object of the
ChannelHandler of the
specified type in this pipeline. |
ChannelHandlerContext |
ChannelPipeline.context(String name)
Returns the context object of the
ChannelHandler with the
specified name in this pipeline. |
ChannelHandlerContext |
ChannelHandlerContext.fireChannelActive()
A
Channel is active now, which means it is connected. |
ChannelHandlerContext |
ChannelHandlerContext.fireChannelInactive()
A
Channel is inactive now, which means it is closed. |
ChannelHandlerContext |
ChannelHandlerContext.fireChannelRead(Object msg)
A
Channel received a message. |
ChannelHandlerContext |
ChannelHandlerContext.fireChannelReadComplete()
Triggers an
ChannelHandler.channelReadComplete(ChannelHandlerContext)
event to the next ChannelHandler in the ChannelPipeline . |
ChannelHandlerContext |
ChannelHandlerContext.fireChannelRegistered()
|
ChannelHandlerContext |
ChannelHandlerContext.fireChannelUnregistered()
|
ChannelHandlerContext |
ChannelHandlerContext.fireChannelWritabilityChanged()
Triggers an
ChannelHandler.channelWritabilityChanged(ChannelHandlerContext)
event to the next ChannelHandler in the ChannelPipeline . |
ChannelHandlerContext |
ChannelHandlerContext.fireExceptionCaught(Throwable cause)
|
ChannelHandlerContext |
ChannelHandlerContext.fireUserEventTriggered(Object event)
A
Channel received an user defined event. |
ChannelHandlerContext |
ChannelPipeline.firstContext()
Returns the context of the first
ChannelHandler in this pipeline. |
ChannelHandlerContext |
ChannelHandlerContext.flush()
Request to flush all pending messages via this ChannelOutboundInvoker.
|
ChannelHandlerContext |
ChannelPipeline.lastContext()
Returns the context of the last
ChannelHandler in this pipeline. |
ChannelHandlerContext |
ChannelHandlerContext.read()
Request to Read data from the
Channel into the first inbound buffer, triggers an
ChannelHandler.channelRead(ChannelHandlerContext, Object) event if data was
read, and triggers a
channelReadComplete event so the
handler can decide to continue reading. |
Modifier and Type | Method and Description |
---|---|
void |
ChannelHandler.bind(ChannelHandlerContext ctx,
SocketAddress localAddress,
ChannelPromise promise)
Called once a bind operation is made.
|
void |
ChannelHandlerAdapter.bind(ChannelHandlerContext ctx,
SocketAddress localAddress,
ChannelPromise promise)
Calls
bind(java.net.SocketAddress, ChannelPromise) to forward
to the next ChannelHandler in the ChannelPipeline . |
void |
ChannelHandler.channelActive(ChannelHandlerContext ctx)
The
Channel of the ChannelHandlerContext is now active |
void |
ChannelHandlerAdapter.channelActive(ChannelHandlerContext ctx)
|
void |
ChannelHandler.channelInactive(ChannelHandlerContext ctx)
The
Channel of the ChannelHandlerContext was registered is now inactive and reached its
end of lifetime. |
void |
ChannelHandlerAdapter.channelInactive(ChannelHandlerContext ctx)
|
void |
ChannelHandler.channelRead(ChannelHandlerContext ctx,
Object msg)
Invoked when the current
Channel has read a message from the peer. |
void |
SimpleChannelInboundHandler.channelRead(ChannelHandlerContext ctx,
Object msg) |
void |
ChannelHandlerAdapter.channelRead(ChannelHandlerContext ctx,
Object msg)
|
void |
ChannelHandler.channelReadComplete(ChannelHandlerContext ctx)
Invoked when the last message read by the current read operation has been consumed by
ChannelHandler.channelRead(ChannelHandlerContext, Object) . |
void |
ChannelHandlerAdapter.channelReadComplete(ChannelHandlerContext ctx)
|
void |
ChannelHandler.channelRegistered(ChannelHandlerContext ctx)
|
void |
ChannelInitializer.channelRegistered(ChannelHandlerContext ctx) |
void |
ChannelHandlerAdapter.channelRegistered(ChannelHandlerContext ctx)
|
void |
ChannelHandler.channelUnregistered(ChannelHandlerContext ctx)
|
void |
ChannelHandlerAdapter.channelUnregistered(ChannelHandlerContext ctx)
|
void |
ChannelHandler.channelWritabilityChanged(ChannelHandlerContext ctx)
Gets called once the writable state of a
Channel changed. |
void |
ChannelHandlerAdapter.channelWritabilityChanged(ChannelHandlerContext ctx)
|
void |
ChannelHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise)
Called once a close operation is made.
|
void |
ChannelHandlerAdapter.close(ChannelHandlerContext ctx,
ChannelPromise promise)
|
void |
ChannelHandler.connect(ChannelHandlerContext ctx,
SocketAddress remoteAddress,
SocketAddress localAddress,
ChannelPromise promise)
Called once a connect operation is made.
|
void |
ChannelHandlerAdapter.connect(ChannelHandlerContext ctx,
SocketAddress remoteAddress,
SocketAddress localAddress,
ChannelPromise promise)
Calls
connect(SocketAddress, SocketAddress, ChannelPromise) to forward
to the next ChannelHandler in the ChannelPipeline . |
void |
ChannelHandler.deregister(ChannelHandlerContext ctx,
ChannelPromise promise)
Called once a deregister operation is made from the current registered
EventLoop . |
void |
ChannelHandlerAdapter.deregister(ChannelHandlerContext ctx,
ChannelPromise promise)
|
void |
ChannelHandler.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise)
Called once a disconnect operation is made.
|
void |
ChannelHandlerAdapter.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise)
|
void |
ChannelHandler.exceptionCaught(ChannelHandlerContext ctx,
Throwable cause)
Gets called if a
Throwable was thrown. |
void |
ChannelHandlerAdapter.exceptionCaught(ChannelHandlerContext ctx,
Throwable cause)
|
void |
ChannelHandler.flush(ChannelHandlerContext ctx)
Called once a flush operation is made.
|
void |
ChannelHandlerAdapter.flush(ChannelHandlerContext ctx)
|
void |
ChannelHandler.handlerAdded(ChannelHandlerContext ctx)
Gets called after the
ChannelHandler was added to the actual context and it's ready to handle events. |
void |
ChannelHandlerAdapter.handlerAdded(ChannelHandlerContext ctx)
Do nothing by default, sub-classes may override this method.
|
void |
ChannelHandlerAppender.handlerAdded(ChannelHandlerContext ctx) |
void |
ChannelHandler.handlerRemoved(ChannelHandlerContext ctx)
Gets called after the
ChannelHandler was removed from the actual context and it doesn't handle events
anymore. |
void |
ChannelHandlerAdapter.handlerRemoved(ChannelHandlerContext ctx)
Do nothing by default, sub-classes may override this method.
|
void |
ChannelHandlerInvoker.invokeBind(ChannelHandlerContext ctx,
SocketAddress localAddress,
ChannelPromise promise)
|
void |
DefaultChannelHandlerInvoker.invokeBind(ChannelHandlerContext ctx,
SocketAddress localAddress,
ChannelPromise promise) |
static void |
ChannelHandlerInvokerUtil.invokeBindNow(ChannelHandlerContext ctx,
SocketAddress localAddress,
ChannelPromise promise) |
void |
ChannelHandlerInvoker.invokeChannelActive(ChannelHandlerContext ctx)
|
void |
DefaultChannelHandlerInvoker.invokeChannelActive(ChannelHandlerContext ctx) |
static void |
ChannelHandlerInvokerUtil.invokeChannelActiveNow(ChannelHandlerContext ctx) |
void |
ChannelHandlerInvoker.invokeChannelInactive(ChannelHandlerContext ctx)
|
void |
DefaultChannelHandlerInvoker.invokeChannelInactive(ChannelHandlerContext ctx) |
static void |
ChannelHandlerInvokerUtil.invokeChannelInactiveNow(ChannelHandlerContext ctx) |
void |
ChannelHandlerInvoker.invokeChannelRead(ChannelHandlerContext ctx,
Object msg)
|
void |
DefaultChannelHandlerInvoker.invokeChannelRead(ChannelHandlerContext ctx,
Object msg) |
void |
ChannelHandlerInvoker.invokeChannelReadComplete(ChannelHandlerContext ctx)
|
void |
DefaultChannelHandlerInvoker.invokeChannelReadComplete(ChannelHandlerContext ctx) |
static void |
ChannelHandlerInvokerUtil.invokeChannelReadCompleteNow(ChannelHandlerContext ctx) |
static void |
ChannelHandlerInvokerUtil.invokeChannelReadNow(ChannelHandlerContext ctx,
Object msg) |
void |
ChannelHandlerInvoker.invokeChannelRegistered(ChannelHandlerContext ctx)
|
void |
DefaultChannelHandlerInvoker.invokeChannelRegistered(ChannelHandlerContext ctx) |
static void |
ChannelHandlerInvokerUtil.invokeChannelRegisteredNow(ChannelHandlerContext ctx) |
void |
ChannelHandlerInvoker.invokeChannelUnregistered(ChannelHandlerContext ctx)
|
void |
DefaultChannelHandlerInvoker.invokeChannelUnregistered(ChannelHandlerContext ctx) |
static void |
ChannelHandlerInvokerUtil.invokeChannelUnregisteredNow(ChannelHandlerContext ctx) |
void |
ChannelHandlerInvoker.invokeChannelWritabilityChanged(ChannelHandlerContext ctx)
|
void |
DefaultChannelHandlerInvoker.invokeChannelWritabilityChanged(ChannelHandlerContext ctx) |
static void |
ChannelHandlerInvokerUtil.invokeChannelWritabilityChangedNow(ChannelHandlerContext ctx) |
void |
ChannelHandlerInvoker.invokeClose(ChannelHandlerContext ctx,
ChannelPromise promise)
|
void |
DefaultChannelHandlerInvoker.invokeClose(ChannelHandlerContext ctx,
ChannelPromise promise) |
static void |
ChannelHandlerInvokerUtil.invokeCloseNow(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
ChannelHandlerInvoker.invokeConnect(ChannelHandlerContext ctx,
SocketAddress remoteAddress,
SocketAddress localAddress,
ChannelPromise promise)
|
void |
DefaultChannelHandlerInvoker.invokeConnect(ChannelHandlerContext ctx,
SocketAddress remoteAddress,
SocketAddress localAddress,
ChannelPromise promise) |
static void |
ChannelHandlerInvokerUtil.invokeConnectNow(ChannelHandlerContext ctx,
SocketAddress remoteAddress,
SocketAddress localAddress,
ChannelPromise promise) |
void |
ChannelHandlerInvoker.invokeDeregister(ChannelHandlerContext ctx,
ChannelPromise promise)
|
void |
DefaultChannelHandlerInvoker.invokeDeregister(ChannelHandlerContext ctx,
ChannelPromise promise) |
static void |
ChannelHandlerInvokerUtil.invokeDeregisterNow(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
ChannelHandlerInvoker.invokeDisconnect(ChannelHandlerContext ctx,
ChannelPromise promise)
|
void |
DefaultChannelHandlerInvoker.invokeDisconnect(ChannelHandlerContext ctx,
ChannelPromise promise) |
static void |
ChannelHandlerInvokerUtil.invokeDisconnectNow(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
ChannelHandlerInvoker.invokeExceptionCaught(ChannelHandlerContext ctx,
Throwable cause)
|
void |
DefaultChannelHandlerInvoker.invokeExceptionCaught(ChannelHandlerContext ctx,
Throwable cause) |
static void |
ChannelHandlerInvokerUtil.invokeExceptionCaughtNow(ChannelHandlerContext ctx,
Throwable cause) |
void |
ChannelHandlerInvoker.invokeFlush(ChannelHandlerContext ctx)
|
void |
DefaultChannelHandlerInvoker.invokeFlush(ChannelHandlerContext ctx) |
static void |
ChannelHandlerInvokerUtil.invokeFlushNow(ChannelHandlerContext ctx) |
void |
ChannelHandlerInvoker.invokeRead(ChannelHandlerContext ctx)
|
void |
DefaultChannelHandlerInvoker.invokeRead(ChannelHandlerContext ctx) |
static void |
ChannelHandlerInvokerUtil.invokeReadNow(ChannelHandlerContext ctx) |
void |
ChannelHandlerInvoker.invokeUserEventTriggered(ChannelHandlerContext ctx,
Object event)
|
void |
DefaultChannelHandlerInvoker.invokeUserEventTriggered(ChannelHandlerContext ctx,
Object event) |
static void |
ChannelHandlerInvokerUtil.invokeUserEventTriggeredNow(ChannelHandlerContext ctx,
Object event) |
void |
ChannelHandlerInvoker.invokeWrite(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise)
|
void |
DefaultChannelHandlerInvoker.invokeWrite(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise) |
static void |
ChannelHandlerInvokerUtil.invokeWriteNow(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise) |
protected abstract void |
SimpleChannelInboundHandler.messageReceived(ChannelHandlerContext ctx,
I msg)
Is called for each message of type
I . |
void |
ChannelHandler.read(ChannelHandlerContext ctx)
Intercepts
read() . |
void |
ChannelHandlerAdapter.read(ChannelHandlerContext ctx)
|
void |
ChannelHandler.userEventTriggered(ChannelHandlerContext ctx,
Object evt)
Gets called if an user event was triggered.
|
void |
ChannelHandlerAdapter.userEventTriggered(ChannelHandlerContext ctx,
Object evt)
|
static boolean |
ChannelHandlerInvokerUtil.validatePromise(ChannelHandlerContext ctx,
ChannelPromise promise,
boolean allowVoidPromise) |
void |
ChannelHandler.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise)
Called once a write operation is made.
|
void |
ChannelHandlerAdapter.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise)
|
Constructor and Description |
---|
PendingWriteQueue(ChannelHandlerContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected ChannelHandlerContext |
MessageAggregator.ctx() |
Modifier and Type | Method and Description |
---|---|
protected ByteBuf |
MessageToByteEncoder.allocateBuffer(ChannelHandlerContext ctx,
I msg,
boolean preferDirect)
Allocate a
ByteBuf which will be used as argument of #encode(ChannelHandlerContext, I, ByteBuf) . |
protected void |
ReplayingDecoder.callDecode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
ByteToMessageDecoder.callDecode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out)
Called once data should be decoded from the given
ByteBuf . |
void |
ReplayingDecoder.channelInactive(ChannelHandlerContext ctx) |
void |
ByteToMessageDecoder.channelInactive(ChannelHandlerContext ctx) |
void |
MessageAggregator.channelInactive(ChannelHandlerContext ctx) |
void |
MessageToMessageDecoder.channelRead(ChannelHandlerContext ctx,
Object msg) |
void |
MessageToMessageCodec.channelRead(ChannelHandlerContext ctx,
Object msg) |
void |
ByteToMessageCodec.channelRead(ChannelHandlerContext ctx,
Object msg) |
void |
ByteToMessageDecoder.channelRead(ChannelHandlerContext ctx,
Object msg) |
void |
ByteToMessageDecoder.channelReadComplete(ChannelHandlerContext ctx) |
protected Object |
FixedLengthFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in)
Create a frame out of the
ByteBuf and return it. |
protected Object |
LineBasedFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf buffer)
Create a frame out of the
ByteBuf and return it. |
protected Object |
DelimiterBasedFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf buffer)
Create a frame out of the
ByteBuf and return it. |
protected Object |
LengthFieldBasedFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in)
Create a frame out of the
ByteBuf and return it. |
protected void |
FixedLengthFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected abstract void |
ByteToMessageCodec.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
LineBasedFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
DelimiterBasedFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected abstract void |
ByteToMessageDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out)
Decode the from one
ByteBuf to an other. |
protected void |
LengthFieldBasedFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected abstract void |
MessageToMessageDecoder.decode(ChannelHandlerContext ctx,
I msg,
List<Object> out)
Decode from one message to an other.
|
protected void |
MessageAggregator.decode(ChannelHandlerContext ctx,
I msg,
List<Object> out) |
protected abstract void |
MessageToMessageCodec.decode(ChannelHandlerContext ctx,
INBOUND_IN msg,
List<Object> out) |
protected void |
ByteToMessageCodec.decodeLast(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
ByteToMessageDecoder.decodeLast(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out)
Is called one last time when the
ChannelHandlerContext goes in-active. |
protected void |
LengthFieldPrepender.encode(ChannelHandlerContext ctx,
ByteBuf msg,
List<Object> out) |
protected abstract void |
ByteToMessageCodec.encode(ChannelHandlerContext ctx,
I msg,
ByteBuf out) |
protected abstract void |
MessageToByteEncoder.encode(ChannelHandlerContext ctx,
I msg,
ByteBuf out)
Encode a message into a
ByteBuf . |
protected abstract void |
MessageToMessageEncoder.encode(ChannelHandlerContext ctx,
I msg,
List<Object> out)
Encode from one message to an other.
|
protected abstract void |
MessageToMessageCodec.encode(ChannelHandlerContext ctx,
OUTBOUND_IN msg,
List<Object> out) |
protected ByteBuf |
LengthFieldBasedFrameDecoder.extractFrame(ChannelHandlerContext ctx,
ByteBuf buffer,
int index,
int length)
Extract the sub-region of the specified buffer.
|
protected void |
MessageAggregator.handleOversizedMessage(ChannelHandlerContext ctx,
S oversized)
Invoked when an incoming request exceeds the maximum content length.
|
void |
MessageAggregator.handlerAdded(ChannelHandlerContext ctx) |
void |
ByteToMessageDecoder.handlerRemoved(ChannelHandlerContext ctx) |
void |
MessageAggregator.handlerRemoved(ChannelHandlerContext ctx) |
protected void |
ByteToMessageDecoder.handlerRemoved0(ChannelHandlerContext ctx)
Gets called after the
ByteToMessageDecoder was removed from the actual context and it doesn't handle
events anymore. |
void |
MessageToMessageEncoder.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise) |
void |
MessageToMessageCodec.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise) |
void |
ByteToMessageCodec.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise) |
void |
MessageToByteEncoder.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
protected void |
Base64Decoder.decode(ChannelHandlerContext ctx,
ByteBuf msg,
List<Object> out) |
protected void |
Base64Encoder.encode(ChannelHandlerContext ctx,
ByteBuf msg,
List<Object> out) |
Modifier and Type | Method and Description |
---|---|
protected void |
ByteArrayDecoder.decode(ChannelHandlerContext ctx,
ByteBuf msg,
List<Object> out) |
protected void |
ByteArrayEncoder.encode(ChannelHandlerContext ctx,
byte[] msg,
List<Object> out) |
Modifier and Type | Method and Description |
---|---|
protected ByteBuf |
LzmaFrameEncoder.allocateBuffer(ChannelHandlerContext ctx,
ByteBuf in,
boolean preferDirect) |
protected ByteBuf |
JdkZlibEncoder.allocateBuffer(ChannelHandlerContext ctx,
ByteBuf msg,
boolean preferDirect) |
void |
Lz4FrameEncoder.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
Bzip2Encoder.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
JZlibEncoder.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
JdkZlibEncoder.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
protected void |
Lz4FrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
JZlibDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
LzfDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
Bzip2Decoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
SnappyFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
FastLzFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
JdkZlibDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
Lz4FrameEncoder.encode(ChannelHandlerContext ctx,
ByteBuf in,
ByteBuf out) |
protected void |
Bzip2Encoder.encode(ChannelHandlerContext ctx,
ByteBuf in,
ByteBuf out) |
protected void |
LzmaFrameEncoder.encode(ChannelHandlerContext ctx,
ByteBuf in,
ByteBuf out) |
protected void |
LzfEncoder.encode(ChannelHandlerContext ctx,
ByteBuf in,
ByteBuf out) |
protected void |
JZlibEncoder.encode(ChannelHandlerContext ctx,
ByteBuf in,
ByteBuf out) |
protected void |
JdkZlibEncoder.encode(ChannelHandlerContext ctx,
ByteBuf uncompressed,
ByteBuf out) |
protected void |
FastLzFrameEncoder.encode(ChannelHandlerContext ctx,
ByteBuf in,
ByteBuf out) |
protected void |
SnappyFrameEncoder.encode(ChannelHandlerContext ctx,
ByteBuf in,
ByteBuf out) |
void |
Lz4FrameEncoder.handlerAdded(ChannelHandlerContext ctx) |
void |
Bzip2Encoder.handlerAdded(ChannelHandlerContext ctx) |
void |
JZlibEncoder.handlerAdded(ChannelHandlerContext ctx) |
void |
JdkZlibEncoder.handlerAdded(ChannelHandlerContext ctx) |
protected void |
JdkZlibDecoder.handlerRemoved0(ChannelHandlerContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected void |
DnsResponseDecoder.decode(ChannelHandlerContext ctx,
DatagramPacket packet,
List<Object> out) |
protected void |
DnsQueryEncoder.encode(ChannelHandlerContext ctx,
DnsQuery query,
List<Object> out) |
Modifier and Type | Method and Description |
---|---|
void |
HAProxyMessageDecoder.channelRead(ChannelHandlerContext ctx,
Object msg) |
protected void |
HAProxyMessageDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
Modifier and Type | Method and Description |
---|---|
void |
HttpContentDecoder.channelInactive(ChannelHandlerContext ctx) |
void |
HttpContentEncoder.channelInactive(ChannelHandlerContext ctx) |
protected void |
HttpObjectDecoder.decode(ChannelHandlerContext ctx,
ByteBuf buffer,
List<Object> out) |
protected void |
HttpClientUpgradeHandler.decode(ChannelHandlerContext ctx,
HttpObject msg,
List<Object> out) |
protected void |
HttpServerUpgradeHandler.decode(ChannelHandlerContext ctx,
HttpObject msg,
List<Object> out) |
protected void |
HttpContentDecoder.decode(ChannelHandlerContext ctx,
HttpObject msg,
List<Object> out) |
protected void |
HttpContentEncoder.decode(ChannelHandlerContext ctx,
HttpRequest msg,
List<Object> out) |
protected void |
HttpObjectDecoder.decodeLast(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
HttpContentEncoder.encode(ChannelHandlerContext ctx,
HttpObject msg,
List<Object> out) |
protected void |
HttpObjectEncoder.encode(ChannelHandlerContext ctx,
Object msg,
List<Object> out) |
protected void |
HttpObjectAggregator.handleOversizedMessage(ChannelHandlerContext ctx,
HttpMessage oversized) |
void |
HttpContentDecoder.handlerRemoved(ChannelHandlerContext ctx) |
void |
HttpContentEncoder.handlerRemoved(ChannelHandlerContext ctx) |
void |
HttpServerUpgradeHandler.UpgradeCodec.prepareUpgradeResponse(ChannelHandlerContext ctx,
FullHttpRequest upgradeRequest,
FullHttpResponse upgradeResponse)
Adds any headers to the 101 Switching protocols response that are appropriate for this protocol.
|
HttpContent |
HttpChunkedInput.readChunk(ChannelHandlerContext ctx) |
Collection<String> |
HttpClientUpgradeHandler.UpgradeCodec.setUpgradeHeaders(ChannelHandlerContext ctx,
HttpRequest upgradeRequest)
Sets any protocol-specific headers required to the upgrade request.
|
void |
HttpClientUpgradeHandler.SourceCodec.upgradeFrom(ChannelHandlerContext ctx)
Removes this codec (i.e. all associated handlers) from the pipeline.
|
void |
HttpServerUpgradeHandler.SourceCodec.upgradeFrom(ChannelHandlerContext ctx)
Removes this codec (i.e. all associated handlers) from the pipeline.
|
void |
HttpClientCodec.upgradeFrom(ChannelHandlerContext ctx)
Upgrades to another protocol from HTTP.
|
void |
HttpServerCodec.upgradeFrom(ChannelHandlerContext ctx)
Upgrades to another protocol from HTTP.
|
void |
HttpServerUpgradeHandler.UpgradeCodec.upgradeTo(ChannelHandlerContext ctx,
FullHttpRequest upgradeRequest,
FullHttpResponse upgradeResponse)
Performs an HTTP protocol upgrade from the source codec.
|
void |
HttpClientUpgradeHandler.UpgradeCodec.upgradeTo(ChannelHandlerContext ctx,
FullHttpResponse upgradeResponse)
Performs an HTTP protocol upgrade from the source codec.
|
void |
HttpClientUpgradeHandler.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
void |
CorsHandler.channelRead(ChannelHandlerContext ctx,
Object msg) |
void |
CorsHandler.exceptionCaught(ChannelHandlerContext ctx,
Throwable cause) |
void |
CorsHandler.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
HttpContent |
HttpPostRequestEncoder.readChunk(ChannelHandlerContext ctx)
Returns the next available HttpChunk.
|
Modifier and Type | Method and Description |
---|---|
void |
Utf8FrameValidator.channelRead(ChannelHandlerContext ctx,
Object msg) |
protected void |
WebSocket08FrameDecoder.checkCloseFrameBody(ChannelHandlerContext ctx,
ByteBuf buffer) |
protected void |
WebSocket00FrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
WebSocket08FrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
WebSocketServerProtocolHandler.decode(ChannelHandlerContext ctx,
WebSocketFrame frame,
List<Object> out) |
protected void |
WebSocketClientProtocolHandler.decode(ChannelHandlerContext ctx,
WebSocketFrame frame,
List<Object> out) |
protected void |
WebSocket00FrameEncoder.encode(ChannelHandlerContext ctx,
WebSocketFrame msg,
List<Object> out) |
protected void |
WebSocket08FrameEncoder.encode(ChannelHandlerContext ctx,
WebSocketFrame msg,
List<Object> out) |
void |
WebSocketServerProtocolHandler.exceptionCaught(ChannelHandlerContext ctx,
Throwable cause) |
void |
WebSocketServerProtocolHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
WebSocketClientProtocolHandler.handlerAdded(ChannelHandlerContext ctx) |
Modifier and Type | Method and Description |
---|---|
void |
WebSocketServerExtensionHandler.channelRead(ChannelHandlerContext ctx,
Object msg) |
void |
WebSocketClientExtensionHandler.channelRead(ChannelHandlerContext ctx,
Object msg) |
void |
WebSocketServerExtensionHandler.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise) |
void |
WebSocketClientExtensionHandler.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise) |
Modifier and Type | Field and Description |
---|---|
protected ChannelHandlerContext |
DefaultHttp2ConnectionEncoder.FlowControlledBase.ctx |
Modifier and Type | Method and Description |
---|---|
protected void |
Http2OrHttpChooser.addHttp2Handlers(ChannelHandlerContext ctx)
Add all
ChannelHandler 's that are needed for HTTP_2. |
protected void |
Http2OrHttpChooser.addHttpHandlers(ChannelHandlerContext ctx)
Add all
ChannelHandler 's that are needed for HTTP. |
void |
Http2ConnectionHandler.channelActive(ChannelHandlerContext ctx) |
void |
Http2ConnectionHandler.channelInactive(ChannelHandlerContext ctx) |
void |
Http2ConnectionHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
Http2LocalFlowController.consumeBytes(ChannelHandlerContext ctx,
Http2Stream stream,
int numBytes)
Indicates that the application has consumed a number of bytes for the given stream and is
therefore ready to receive more data from the remote endpoint.
|
void |
DefaultHttp2LocalFlowController.consumeBytes(ChannelHandlerContext ctx,
Http2Stream stream,
int numBytes) |
protected void |
Http2OrHttpChooser.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
Http2ConnectionHandler.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
void |
Http2ConnectionDecoder.decodeFrame(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out)
Called by the
Http2ConnectionHandler to decode the next frame from the input buffer. |
void |
DefaultHttp2ConnectionDecoder.decodeFrame(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
void |
Http2ConnectionHandler.exceptionCaught(ChannelHandlerContext ctx,
Throwable cause)
Handles
Http2Exception objects that were thrown from other handlers. |
protected void |
InboundHttp2ToHttpAdapter.fireChannelRead(ChannelHandlerContext ctx,
FullHttpMessage msg,
int streamId)
Set final headers and fire a channel read event
|
protected void |
InboundHttp2ToHttpPriorityAdapter.fireChannelRead(ChannelHandlerContext ctx,
FullHttpMessage msg,
int streamId) |
void |
DefaultHttp2StreamRemovalPolicy.handlerAdded(ChannelHandlerContext ctx) |
void |
Http2ConnectionHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
DefaultHttp2StreamRemovalPolicy.handlerRemoved(ChannelHandlerContext ctx) |
protected void |
Http2ConnectionHandler.handlerRemoved0(ChannelHandlerContext ctx) |
void |
Http2FlowController.incrementWindowSize(ChannelHandlerContext ctx,
Http2Stream stream,
int delta)
Increments the size of the stream's flow control window by the given delta.
|
void |
DefaultHttp2RemoteFlowController.incrementWindowSize(ChannelHandlerContext ctx,
Http2Stream stream,
int delta) |
void |
DefaultHttp2LocalFlowController.incrementWindowSize(ChannelHandlerContext ctx,
Http2Stream stream,
int delta) |
protected void |
Http2ConnectionHandler.onConnectionError(ChannelHandlerContext ctx,
Throwable cause,
Http2Exception http2Ex)
Handler for a connection error.
|
int |
Http2FrameAdapter.onDataRead(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endOfStream) |
int |
Http2EventAdapter.onDataRead(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endOfStream) |
int |
InboundHttp2ToHttpAdapter.onDataRead(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endOfStream) |
int |
Http2FrameListener.onDataRead(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endOfStream)
Handles an inbound
DATA frame. |
int |
DelegatingDecompressorFrameListener.onDataRead(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endOfStream) |
int |
Http2FrameListenerDecorator.onDataRead(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endOfStream) |
void |
Http2LifecycleManager.onException(ChannelHandlerContext ctx,
Throwable cause)
Processes the given exception.
|
void |
Http2ConnectionHandler.onException(ChannelHandlerContext ctx,
Throwable cause)
Central handler for all exceptions caught during HTTP/2 processing.
|
void |
Http2FrameAdapter.onGoAwayRead(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData) |
void |
Http2EventAdapter.onGoAwayRead(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData) |
void |
Http2FrameListener.onGoAwayRead(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData)
Handles an inbound GO_AWAY frame.
|
void |
Http2FrameListenerDecorator.onGoAwayRead(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData) |
void |
Http2FrameAdapter.onHeadersRead(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int padding,
boolean endStream) |
void |
Http2EventAdapter.onHeadersRead(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int padding,
boolean endStream) |
void |
InboundHttp2ToHttpAdapter.onHeadersRead(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int padding,
boolean endOfStream) |
void |
Http2FrameListener.onHeadersRead(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int padding,
boolean endOfStream)
Handles an inbound HEADERS frame.
|
void |
DelegatingDecompressorFrameListener.onHeadersRead(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int padding,
boolean endStream) |
void |
Http2FrameListenerDecorator.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 |
Http2EventAdapter.onHeadersRead(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int streamDependency,
short weight,
boolean exclusive,
int padding,
boolean endStream) |
void |
InboundHttp2ToHttpAdapter.onHeadersRead(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int streamDependency,
short weight,
boolean exclusive,
int padding,
boolean endOfStream) |
void |
Http2FrameListener.onHeadersRead(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int streamDependency,
short weight,
boolean exclusive,
int padding,
boolean endOfStream)
Handles an inbound HEADERS frame with priority information specified.
|
void |
DelegatingDecompressorFrameListener.onHeadersRead(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int streamDependency,
short weight,
boolean exclusive,
int padding,
boolean endStream) |
void |
Http2FrameListenerDecorator.onHeadersRead(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int streamDependency,
short weight,
boolean exclusive,
int padding,
boolean endStream) |
void |
Http2FrameAdapter.onPingAckRead(ChannelHandlerContext ctx,
ByteBuf data) |
void |
Http2EventAdapter.onPingAckRead(ChannelHandlerContext ctx,
ByteBuf data) |
void |
Http2FrameListener.onPingAckRead(ChannelHandlerContext ctx,
ByteBuf data)
Handles an inbound PING acknowledgment.
|
void |
Http2FrameListenerDecorator.onPingAckRead(ChannelHandlerContext ctx,
ByteBuf data) |
void |
Http2FrameAdapter.onPingRead(ChannelHandlerContext ctx,
ByteBuf data) |
void |
Http2EventAdapter.onPingRead(ChannelHandlerContext ctx,
ByteBuf data) |
void |
Http2FrameListener.onPingRead(ChannelHandlerContext ctx,
ByteBuf data)
Handles an inbound PING frame.
|
void |
Http2FrameListenerDecorator.onPingRead(ChannelHandlerContext ctx,
ByteBuf data) |
void |
Http2FrameAdapter.onPriorityRead(ChannelHandlerContext ctx,
int streamId,
int streamDependency,
short weight,
boolean exclusive) |
void |
Http2EventAdapter.onPriorityRead(ChannelHandlerContext ctx,
int streamId,
int streamDependency,
short weight,
boolean exclusive) |
void |
Http2FrameListener.onPriorityRead(ChannelHandlerContext ctx,
int streamId,
int streamDependency,
short weight,
boolean exclusive)
Handles an inbound PRIORITY frame.
|
void |
InboundHttp2ToHttpPriorityAdapter.onPriorityRead(ChannelHandlerContext ctx,
int streamId,
int streamDependency,
short weight,
boolean exclusive) |
void |
Http2FrameListenerDecorator.onPriorityRead(ChannelHandlerContext ctx,
int streamId,
int streamDependency,
short weight,
boolean exclusive) |
void |
Http2FrameAdapter.onPushPromiseRead(ChannelHandlerContext ctx,
int streamId,
int promisedStreamId,
Http2Headers headers,
int padding) |
void |
Http2EventAdapter.onPushPromiseRead(ChannelHandlerContext ctx,
int streamId,
int promisedStreamId,
Http2Headers headers,
int padding) |
void |
InboundHttp2ToHttpAdapter.onPushPromiseRead(ChannelHandlerContext ctx,
int streamId,
int promisedStreamId,
Http2Headers headers,
int padding) |
void |
Http2FrameListener.onPushPromiseRead(ChannelHandlerContext ctx,
int streamId,
int promisedStreamId,
Http2Headers headers,
int padding)
Handles an inbound PUSH_PROMISE frame.
|
void |
Http2FrameListenerDecorator.onPushPromiseRead(ChannelHandlerContext ctx,
int streamId,
int promisedStreamId,
Http2Headers headers,
int padding) |
void |
Http2FrameAdapter.onRstStreamRead(ChannelHandlerContext ctx,
int streamId,
long errorCode) |
void |
Http2EventAdapter.onRstStreamRead(ChannelHandlerContext ctx,
int streamId,
long errorCode) |
void |
InboundHttp2ToHttpAdapter.onRstStreamRead(ChannelHandlerContext ctx,
int streamId,
long errorCode) |
void |
Http2FrameListener.onRstStreamRead(ChannelHandlerContext ctx,
int streamId,
long errorCode)
Handles an inbound RST_STREAM frame.
|
void |
Http2FrameListenerDecorator.onRstStreamRead(ChannelHandlerContext ctx,
int streamId,
long errorCode) |
void |
Http2FrameAdapter.onSettingsAckRead(ChannelHandlerContext ctx) |
void |
Http2EventAdapter.onSettingsAckRead(ChannelHandlerContext ctx) |
void |
Http2FrameListener.onSettingsAckRead(ChannelHandlerContext ctx)
Handles an inbound SETTINGS acknowledgment frame.
|
void |
Http2FrameListenerDecorator.onSettingsAckRead(ChannelHandlerContext ctx) |
void |
Http2FrameAdapter.onSettingsRead(ChannelHandlerContext ctx,
Http2Settings settings) |
void |
Http2EventAdapter.onSettingsRead(ChannelHandlerContext ctx,
Http2Settings settings) |
void |
InboundHttp2ToHttpAdapter.onSettingsRead(ChannelHandlerContext ctx,
Http2Settings settings) |
void |
Http2FrameListener.onSettingsRead(ChannelHandlerContext ctx,
Http2Settings settings)
Handles an inbound SETTINGS frame.
|
void |
Http2FrameListenerDecorator.onSettingsRead(ChannelHandlerContext ctx,
Http2Settings settings) |
protected void |
Http2ConnectionHandler.onStreamError(ChannelHandlerContext ctx,
Throwable cause,
Http2Exception.StreamException http2Ex)
Handler for a stream error.
|
void |
Http2FrameAdapter.onUnknownFrame(ChannelHandlerContext ctx,
byte frameType,
int streamId,
Http2Flags flags,
ByteBuf payload) |
void |
Http2EventAdapter.onUnknownFrame(ChannelHandlerContext ctx,
byte frameType,
int streamId,
Http2Flags flags,
ByteBuf payload) |
void |
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) |
void |
Http2FrameAdapter.onWindowUpdateRead(ChannelHandlerContext ctx,
int streamId,
int windowSizeIncrement) |
void |
Http2EventAdapter.onWindowUpdateRead(ChannelHandlerContext ctx,
int streamId,
int windowSizeIncrement) |
void |
Http2FrameListener.onWindowUpdateRead(ChannelHandlerContext ctx,
int streamId,
int windowSizeIncrement)
Handles an inbound WINDOW_UPDATE frame.
|
void |
Http2FrameListenerDecorator.onWindowUpdateRead(ChannelHandlerContext ctx,
int streamId,
int windowSizeIncrement) |
void |
Http2ServerUpgradeCodec.prepareUpgradeResponse(ChannelHandlerContext ctx,
FullHttpRequest upgradeRequest,
FullHttpResponse upgradeResponse) |
protected FullHttpMessage |
InboundHttp2ToHttpAdapter.processHeadersBegin(ChannelHandlerContext ctx,
int streamId,
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.
|
protected FullHttpMessage |
InboundHttp2ToHttpPriorityAdapter.processHeadersBegin(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
boolean endOfStream,
boolean allowAppend,
boolean appendToTrailer) |
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) |
void |
Http2LocalFlowController.receiveFlowControlledFrame(ChannelHandlerContext ctx,
Http2Stream stream,
ByteBuf data,
int padding,
boolean endOfStream)
Receives an inbound
DATA frame from the remote endpoint and applies flow control
policies to it for both the stream as well as the connection. |
void |
DefaultHttp2LocalFlowController.receiveFlowControlledFrame(ChannelHandlerContext ctx,
Http2Stream stream,
ByteBuf data,
int padding,
boolean endOfStream) |
void |
DefaultHttp2RemoteFlowController.sendFlowControlled(ChannelHandlerContext ctx,
Http2Stream stream,
Http2RemoteFlowController.FlowControlled payload) |
void |
Http2RemoteFlowController.sendFlowControlled(ChannelHandlerContext ctx,
Http2Stream stream,
Http2RemoteFlowController.FlowControlled payload)
Writes or queues a payload for transmission to the remote endpoint.
|
Collection<String> |
Http2ClientUpgradeCodec.setUpgradeHeaders(ChannelHandlerContext ctx,
HttpRequest upgradeRequest) |
static ByteBuf |
Http2CodecUtil.toByteBuf(ChannelHandlerContext ctx,
Throwable cause)
Creates a buffer containing the error message from the given exception.
|
void |
Http2ServerUpgradeCodec.upgradeTo(ChannelHandlerContext ctx,
FullHttpRequest upgradeRequest,
FullHttpResponse upgradeResponse) |
void |
Http2ClientUpgradeCodec.upgradeTo(ChannelHandlerContext ctx,
FullHttpResponse upgradeResponse) |
void |
DefaultHttp2LocalFlowController.windowUpdateRatio(ChannelHandlerContext ctx,
Http2Stream stream,
float ratio)
The window update ratio is used to determine when a window update must be sent.
|
void |
HttpToHttp2ConnectionHandler.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise)
Handles conversion of a
FullHttpMessage to HTTP/2 frames. |
ChannelFuture |
Http2DataWriter.writeData(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endStream,
ChannelPromise promise)
Writes a
DATA frame to the remote endpoint. |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writeData(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endOfStream,
ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writeData(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endStream,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2FrameWriter.writeData(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endStream,
ChannelPromise promise) |
ChannelFuture |
CompressorHttp2ConnectionEncoder.writeData(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endOfStream,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writeFrame(ChannelHandlerContext ctx,
byte frameType,
int streamId,
Http2Flags flags,
ByteBuf payload,
ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writeFrame(ChannelHandlerContext ctx,
byte frameType,
int streamId,
Http2Flags flags,
ByteBuf payload,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2FrameWriter.writeFrame(ChannelHandlerContext ctx,
byte frameType,
int streamId,
Http2Flags flags,
ByteBuf payload,
ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writeFrame(ChannelHandlerContext ctx,
byte frameType,
int streamId,
Http2Flags flags,
ByteBuf payload,
ChannelPromise promise)
Generic write method for any HTTP/2 frame.
|
ChannelFuture |
Http2ConnectionEncoder.writeFrame(ChannelHandlerContext ctx,
byte frameType,
int streamId,
Http2Flags flags,
ByteBuf payload,
ChannelPromise promise)
Writes the given data to the internal
Http2FrameWriter without performing any
state checks on the connection/stream. |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writeGoAway(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData,
ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writeGoAway(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData,
ChannelPromise promise) |
ChannelFuture |
Http2LifecycleManager.writeGoAway(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData,
ChannelPromise promise)
Sends a
GO_AWAY frame to the remote endpoint and updates the connection state
appropriately. |
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 |
Http2ConnectionHandler.writeGoAway(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData,
ChannelPromise promise)
Sends a
GO_AWAY frame to the remote endpoint and updates the connection state appropriately. |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writeHeaders(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int padding,
boolean endStream,
ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writeHeaders(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int padding,
boolean endStream,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2FrameWriter.writeHeaders(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int padding,
boolean endStream,
ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writeHeaders(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int padding,
boolean endStream,
ChannelPromise promise)
Writes a HEADERS frame to the remote endpoint.
|
ChannelFuture |
CompressorHttp2ConnectionEncoder.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 |
Http2OutboundFrameLogger.writeHeaders(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int streamDependency,
short weight,
boolean exclusive,
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 streamDependency,
short weight,
boolean exclusive,
int padding,
boolean endStream,
ChannelPromise promise)
Writes a HEADERS frame with priority specified to the remote endpoint.
|
ChannelFuture |
CompressorHttp2ConnectionEncoder.writeHeaders(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int streamDependency,
short weight,
boolean exclusive,
int padding,
boolean endOfStream,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writePing(ChannelHandlerContext ctx,
boolean ack,
ByteBuf data,
ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writePing(ChannelHandlerContext ctx,
boolean ack,
ByteBuf data,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2FrameWriter.writePing(ChannelHandlerContext ctx,
boolean ack,
ByteBuf data,
ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writePing(ChannelHandlerContext ctx,
boolean ack,
ByteBuf data,
ChannelPromise promise)
Writes a PING frame to the remote endpoint.
|
ChannelFuture |
DefaultHttp2ConnectionEncoder.writePriority(ChannelHandlerContext ctx,
int streamId,
int streamDependency,
short weight,
boolean exclusive,
ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writePriority(ChannelHandlerContext ctx,
int streamId,
int streamDependency,
short weight,
boolean exclusive,
ChannelPromise promise) |
ChannelFuture |
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 |
DefaultHttp2ConnectionEncoder.writePushPromise(ChannelHandlerContext ctx,
int streamId,
int promisedStreamId,
Http2Headers headers,
int padding,
ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writePushPromise(ChannelHandlerContext ctx,
int streamId,
int promisedStreamId,
Http2Headers headers,
int padding,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2FrameWriter.writePushPromise(ChannelHandlerContext ctx,
int streamId,
int promisedStreamId,
Http2Headers headers,
int padding,
ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writePushPromise(ChannelHandlerContext ctx,
int streamId,
int promisedStreamId,
Http2Headers headers,
int padding,
ChannelPromise promise)
Writes a PUSH_PROMISE frame to the remote endpoint.
|
ChannelFuture |
DefaultHttp2ConnectionEncoder.writeRstStream(ChannelHandlerContext ctx,
int streamId,
long errorCode,
ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writeRstStream(ChannelHandlerContext ctx,
int streamId,
long errorCode,
ChannelPromise promise) |
ChannelFuture |
Http2LifecycleManager.writeRstStream(ChannelHandlerContext ctx,
int streamId,
long errorCode,
ChannelPromise promise)
Writes a
RST_STREAM frame to the remote endpoint and updates the connection state
appropriately. |
ChannelFuture |
DefaultHttp2FrameWriter.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 |
Http2ConnectionHandler.writeRstStream(ChannelHandlerContext ctx,
int streamId,
long errorCode,
ChannelPromise promise)
Writes a
RST_STREAM frame to the remote endpoint and updates the connection state appropriately. |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writeRstStream(ChannelHandlerContext ctx,
int streamId,
long errorCode,
ChannelPromise promise,
boolean writeIfNoStream)
Writes a RST_STREAM frame to the remote endpoint.
|
ChannelFuture |
DefaultHttp2ConnectionEncoder.writeSettings(ChannelHandlerContext ctx,
Http2Settings settings,
ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.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 |
DefaultHttp2ConnectionEncoder.writeSettingsAck(ChannelHandlerContext ctx,
ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writeSettingsAck(ChannelHandlerContext ctx,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2FrameWriter.writeSettingsAck(ChannelHandlerContext ctx,
ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writeSettingsAck(ChannelHandlerContext ctx,
ChannelPromise promise)
Writes a SETTINGS acknowledgment to the remote endpoint.
|
ChannelFuture |
DefaultHttp2ConnectionEncoder.writeWindowUpdate(ChannelHandlerContext ctx,
int streamId,
int windowSizeIncrement,
ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.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.
|
Constructor and Description |
---|
DefaultHttp2ConnectionEncoder.FlowControlledBase(ChannelHandlerContext ctx,
Http2Stream stream,
int padding,
boolean endOfStream,
ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
protected void |
JsonObjectDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected ByteBuf |
JsonObjectDecoder.extractObject(ChannelHandlerContext ctx,
ByteBuf buffer,
int index,
int length)
Override this method if you want to filter the json objects/arrays that get passed through the pipeline.
|
Modifier and Type | Method and Description |
---|---|
protected Object |
MarshallingDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in) |
protected void |
CompatibleMarshallingDecoder.decode(ChannelHandlerContext ctx,
ByteBuf buffer,
List<Object> out) |
protected void |
CompatibleMarshallingDecoder.decodeLast(ChannelHandlerContext ctx,
ByteBuf buffer,
List<Object> out) |
protected void |
CompatibleMarshallingEncoder.encode(ChannelHandlerContext ctx,
Object msg,
ByteBuf out) |
protected void |
MarshallingEncoder.encode(ChannelHandlerContext ctx,
Object msg,
ByteBuf out) |
void |
CompatibleMarshallingDecoder.exceptionCaught(ChannelHandlerContext ctx,
Throwable cause) |
protected ByteBuf |
MarshallingDecoder.extractFrame(ChannelHandlerContext ctx,
ByteBuf buffer,
int index,
int length) |
org.jboss.marshalling.Marshaller |
ThreadLocalMarshallerProvider.getMarshaller(ChannelHandlerContext ctx) |
org.jboss.marshalling.Marshaller |
MarshallerProvider.getMarshaller(ChannelHandlerContext ctx)
Get a
Marshaller for the given ChannelHandlerContext |
org.jboss.marshalling.Marshaller |
DefaultMarshallerProvider.getMarshaller(ChannelHandlerContext ctx) |
org.jboss.marshalling.Unmarshaller |
ContextBoundUnmarshallerProvider.getUnmarshaller(ChannelHandlerContext ctx) |
org.jboss.marshalling.Unmarshaller |
ThreadLocalUnmarshallerProvider.getUnmarshaller(ChannelHandlerContext ctx) |
org.jboss.marshalling.Unmarshaller |
UnmarshallerProvider.getUnmarshaller(ChannelHandlerContext ctx)
Get the
Unmarshaller for the given ChannelHandlerContext |
org.jboss.marshalling.Unmarshaller |
DefaultUnmarshallerProvider.getUnmarshaller(ChannelHandlerContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractMemcacheObjectEncoder.encode(ChannelHandlerContext ctx,
Object msg,
List<Object> out) |
protected abstract ByteBuf |
AbstractMemcacheObjectEncoder.encodeMessage(ChannelHandlerContext ctx,
M msg)
Take the given
MemcacheMessage and encode it into a writable ByteBuf . |
Modifier and Type | Method and Description |
---|---|
void |
AbstractBinaryMemcacheDecoder.channelInactive(ChannelHandlerContext ctx)
When the channel goes inactive, release all frames to prevent data leaks.
|
protected void |
AbstractBinaryMemcacheDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected ByteBuf |
AbstractBinaryMemcacheEncoder.encodeMessage(ChannelHandlerContext ctx,
M msg) |
Modifier and Type | Method and Description |
---|---|
protected void |
MqttDecoder.decode(ChannelHandlerContext ctx,
ByteBuf buffer,
List<Object> out) |
protected void |
MqttEncoder.encode(ChannelHandlerContext ctx,
MqttMessage msg,
List<Object> out) |
Modifier and Type | Method and Description |
---|---|
protected void |
ProtobufVarint32FrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
ProtobufDecoder.decode(ChannelHandlerContext ctx,
ByteBuf msg,
List<Object> out) |
protected void |
ProtobufVarint32LengthFieldPrepender.encode(ChannelHandlerContext ctx,
ByteBuf msg,
ByteBuf out) |
protected void |
ProtobufEncoder.encode(ChannelHandlerContext ctx,
com.google.protobuf.MessageLiteOrBuilder msg,
List<Object> out) |
Modifier and Type | Method and Description |
---|---|
protected void |
SctpInboundByteStreamHandler.decode(ChannelHandlerContext ctx,
SctpMessage msg,
List<Object> out) |
protected void |
SctpMessageCompletionHandler.decode(ChannelHandlerContext ctx,
SctpMessage msg,
List<Object> out) |
protected void |
SctpOutboundByteStreamHandler.encode(ChannelHandlerContext ctx,
ByteBuf msg,
List<Object> out) |
Modifier and Type | Method and Description |
---|---|
protected Object |
ObjectDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in) |
protected void |
ObjectEncoder.encode(ChannelHandlerContext ctx,
Serializable msg,
ByteBuf out) |
protected void |
CompatibleObjectEncoder.encode(ChannelHandlerContext ctx,
Serializable msg,
ByteBuf out) |
protected ByteBuf |
ObjectDecoder.extractFrame(ChannelHandlerContext ctx,
ByteBuf buffer,
int index,
int length) |
Modifier and Type | Method and Description |
---|---|
protected void |
SocksPortUnificationServerHandler.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
Modifier and Type | Method and Description |
---|---|
protected void |
Socks4ServerDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
Socks4ClientDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
Socks4ClientEncoder.encode(ChannelHandlerContext ctx,
Socks4CommandRequest msg,
ByteBuf out) |
protected void |
Socks4ServerEncoder.encode(ChannelHandlerContext ctx,
Socks4CommandResponse msg,
ByteBuf out) |
Modifier and Type | Method and Description |
---|---|
protected void |
Socks5PasswordAuthRequestDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
Socks5CommandResponseDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
Socks5PasswordAuthResponseDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
Socks5InitialRequestDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
Socks5InitialResponseDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
Socks5CommandRequestDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
Socks5ServerEncoder.encode(ChannelHandlerContext ctx,
Socks5Message msg,
ByteBuf out) |
protected void |
Socks5ClientEncoder.encode(ChannelHandlerContext ctx,
Socks5Message msg,
ByteBuf out) |
Modifier and Type | Method and Description |
---|---|
protected void |
SpdyOrHttpChooser.addHttpHandlers(ChannelHandlerContext ctx)
Add all
ChannelHandler 's that are needed for HTTP. |
protected void |
SpdyOrHttpChooser.addSpdyHandlers(ChannelHandlerContext ctx,
SpdyVersion version)
Add all
ChannelHandler 's that are needed for SPDY with the given version. |
void |
SpdySessionHandler.channelInactive(ChannelHandlerContext ctx) |
void |
SpdySessionHandler.channelRead(ChannelHandlerContext ctx,
Object msg) |
void |
SpdySessionHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
protected void |
SpdyFrameCodec.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
SpdyOrHttpChooser.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
SpdyHttpResponseStreamIdHandler.decode(ChannelHandlerContext ctx,
Object msg,
List<Object> out) |
protected void |
SpdyHttpDecoder.decode(ChannelHandlerContext ctx,
SpdyFrame msg,
List<Object> out) |
protected void |
SpdyHttpResponseStreamIdHandler.encode(ChannelHandlerContext ctx,
HttpMessage msg,
List<Object> out) |
protected void |
SpdyHttpEncoder.encode(ChannelHandlerContext ctx,
HttpObject msg,
List<Object> out) |
void |
SpdySessionHandler.exceptionCaught(ChannelHandlerContext ctx,
Throwable cause) |
void |
SpdyFrameCodec.handlerAdded(ChannelHandlerContext ctx) |
void |
SpdySessionHandler.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise) |
void |
SpdyFrameCodec.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
protected void |
StompSubframeDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
StompSubframeEncoder.encode(ChannelHandlerContext ctx,
StompSubframe msg,
List<Object> out) |
Modifier and Type | Method and Description |
---|---|
protected void |
StringDecoder.decode(ChannelHandlerContext ctx,
ByteBuf msg,
List<Object> out) |
protected void |
StringEncoder.encode(ChannelHandlerContext ctx,
CharSequence msg,
List<Object> out) |
Modifier and Type | Method and Description |
---|---|
protected void |
XmlFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
RuleBasedIpFilter.accept(ChannelHandlerContext ctx,
InetSocketAddress remoteAddress) |
protected boolean |
UniqueIpFilter.accept(ChannelHandlerContext ctx,
InetSocketAddress remoteAddress) |
protected abstract boolean |
AbstractRemoteAddressFilter.accept(ChannelHandlerContext ctx,
T remoteAddress)
This method is called immediately after a
Channel gets registered. |
protected void |
AbstractRemoteAddressFilter.channelAccepted(ChannelHandlerContext ctx,
T remoteAddress)
This method is called if
remoteAddress gets accepted by
AbstractRemoteAddressFilter.accept(ChannelHandlerContext, SocketAddress) . |
void |
AbstractRemoteAddressFilter.channelActive(ChannelHandlerContext ctx) |
void |
AbstractRemoteAddressFilter.channelRegistered(ChannelHandlerContext ctx) |
protected ChannelFuture |
AbstractRemoteAddressFilter.channelRejected(ChannelHandlerContext ctx,
T remoteAddress)
This method is called if
remoteAddress gets rejected by
AbstractRemoteAddressFilter.accept(ChannelHandlerContext, SocketAddress) . |
Modifier and Type | Method and Description |
---|---|
void |
LoggingHandler.bind(ChannelHandlerContext ctx,
SocketAddress localAddress,
ChannelPromise promise) |
void |
LoggingHandler.channelActive(ChannelHandlerContext ctx) |
void |
LoggingHandler.channelInactive(ChannelHandlerContext ctx) |
void |
LoggingHandler.channelRead(ChannelHandlerContext ctx,
Object msg) |
void |
LoggingHandler.channelRegistered(ChannelHandlerContext ctx) |
void |
LoggingHandler.channelUnregistered(ChannelHandlerContext ctx) |
void |
LoggingHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
LoggingHandler.connect(ChannelHandlerContext ctx,
SocketAddress remoteAddress,
SocketAddress localAddress,
ChannelPromise promise) |
void |
LoggingHandler.deregister(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
LoggingHandler.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
LoggingHandler.exceptionCaught(ChannelHandlerContext ctx,
Throwable cause) |
void |
LoggingHandler.flush(ChannelHandlerContext ctx) |
protected String |
LoggingHandler.format(ChannelHandlerContext ctx,
String eventName)
Formats an event and returns the formatted message.
|
protected String |
LoggingHandler.format(ChannelHandlerContext ctx,
String eventName,
Object arg)
Formats an event and returns the formatted message.
|
protected String |
LoggingHandler.format(ChannelHandlerContext ctx,
String eventName,
Object firstArg,
Object secondArg)
Formats an event and returns the formatted message.
|
void |
LoggingHandler.userEventTriggered(ChannelHandlerContext ctx,
Object evt) |
void |
LoggingHandler.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
protected void |
Socks5ProxyHandler.addCodec(ChannelHandlerContext ctx) |
protected 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 |
HttpProxyHandler.addCodec(ChannelHandlerContext ctx) |
void |
ProxyHandler.channelActive(ChannelHandlerContext ctx) |
void |
ProxyHandler.channelInactive(ChannelHandlerContext ctx) |
void |
ProxyHandler.channelRead(ChannelHandlerContext ctx,
Object msg) |
void |
ProxyHandler.channelReadComplete(ChannelHandlerContext ctx) |
void |
ProxyHandler.connect(ChannelHandlerContext ctx,
SocketAddress remoteAddress,
SocketAddress localAddress,
ChannelPromise promise) |
void |
ProxyHandler.exceptionCaught(ChannelHandlerContext ctx,
Throwable cause) |
void |
ProxyHandler.flush(ChannelHandlerContext ctx) |
void |
ProxyHandler.handlerAdded(ChannelHandlerContext ctx) |
protected boolean |
Socks5ProxyHandler.handleResponse(ChannelHandlerContext ctx,
Object response) |
protected abstract boolean |
ProxyHandler.handleResponse(ChannelHandlerContext ctx,
Object response)
Handles the message received from the proxy server.
|
protected boolean |
Socks4ProxyHandler.handleResponse(ChannelHandlerContext ctx,
Object response) |
protected boolean |
HttpProxyHandler.handleResponse(ChannelHandlerContext ctx,
Object response) |
protected Object |
Socks5ProxyHandler.newInitialMessage(ChannelHandlerContext ctx) |
protected abstract Object |
ProxyHandler.newInitialMessage(ChannelHandlerContext ctx)
Returns a new message that is sent at first time when the connection to the proxy server has been established.
|
protected Object |
Socks4ProxyHandler.newInitialMessage(ChannelHandlerContext ctx) |
protected Object |
HttpProxyHandler.newInitialMessage(ChannelHandlerContext ctx) |
protected void |
Socks5ProxyHandler.removeDecoder(ChannelHandlerContext ctx) |
protected abstract void |
ProxyHandler.removeDecoder(ChannelHandlerContext ctx)
Removes the decoders added in
ProxyHandler.addCodec(ChannelHandlerContext) . |
protected void |
Socks4ProxyHandler.removeDecoder(ChannelHandlerContext ctx) |
protected void |
HttpProxyHandler.removeDecoder(ChannelHandlerContext ctx) |
protected void |
Socks5ProxyHandler.removeEncoder(ChannelHandlerContext ctx) |
protected abstract void |
ProxyHandler.removeEncoder(ChannelHandlerContext ctx)
Removes the encoders added in
ProxyHandler.addCodec(ChannelHandlerContext) . |
protected void |
Socks4ProxyHandler.removeEncoder(ChannelHandlerContext ctx) |
protected void |
HttpProxyHandler.removeEncoder(ChannelHandlerContext ctx) |
void |
ProxyHandler.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
void |
SslHandler.channelActive(ChannelHandlerContext ctx)
Issues an initial TLS handshake once connected when used in client-mode
|
void |
SslHandler.channelInactive(ChannelHandlerContext ctx) |
void |
SslHandler.channelReadComplete(ChannelHandlerContext ctx) |
void |
SslHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
protected void |
SniHandler.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
SslHandler.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
void |
SslHandler.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
SslHandler.exceptionCaught(ChannelHandlerContext ctx,
Throwable cause) |
void |
SslHandler.flush(ChannelHandlerContext ctx) |
void |
SslHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
SslHandler.handlerRemoved0(ChannelHandlerContext ctx) |
void |
SslHandler.read(ChannelHandlerContext ctx) |
void |
SslHandler.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
void |
ChunkedWriteHandler.channelInactive(ChannelHandlerContext ctx) |
void |
ChunkedWriteHandler.channelWritabilityChanged(ChannelHandlerContext ctx) |
void |
ChunkedWriteHandler.flush(ChannelHandlerContext ctx) |
void |
ChunkedWriteHandler.handlerAdded(ChannelHandlerContext ctx) |
ByteBuf |
ChunkedStream.readChunk(ChannelHandlerContext ctx) |
ByteBuf |
ChunkedNioStream.readChunk(ChannelHandlerContext ctx) |
ByteBuf |
ChunkedNioFile.readChunk(ChannelHandlerContext ctx) |
B |
ChunkedInput.readChunk(ChannelHandlerContext ctx)
Fetches a chunked data from the stream.
|
ByteBuf |
ChunkedFile.readChunk(ChannelHandlerContext ctx) |
void |
ChunkedWriteHandler.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
void |
ReadTimeoutHandler.channelActive(ChannelHandlerContext ctx) |
void |
IdleStateHandler.channelActive(ChannelHandlerContext ctx) |
protected void |
IdleStateHandler.channelIdle(ChannelHandlerContext ctx,
IdleStateEvent evt)
Is called when an
IdleStateEvent should be fired. |
void |
ReadTimeoutHandler.channelInactive(ChannelHandlerContext ctx) |
void |
IdleStateHandler.channelInactive(ChannelHandlerContext ctx) |
void |
ReadTimeoutHandler.channelRead(ChannelHandlerContext ctx,
Object msg) |
void |
IdleStateHandler.channelRead(ChannelHandlerContext ctx,
Object msg) |
void |
ReadTimeoutHandler.channelRegistered(ChannelHandlerContext ctx) |
void |
IdleStateHandler.channelRegistered(ChannelHandlerContext ctx) |
void |
ReadTimeoutHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
IdleStateHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
ReadTimeoutHandler.handlerRemoved(ChannelHandlerContext ctx) |
void |
IdleStateHandler.handlerRemoved(ChannelHandlerContext ctx) |
protected void |
ReadTimeoutHandler.readTimedOut(ChannelHandlerContext ctx)
Is called when a read timeout was detected.
|
void |
IdleStateHandler.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise) |
void |
WriteTimeoutHandler.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise) |
protected void |
WriteTimeoutHandler.writeTimedOut(ChannelHandlerContext ctx)
Is called when a write timeout was detected
|
Modifier and Type | Method and Description |
---|---|
void |
GlobalChannelTrafficShapingHandler.channelRead(ChannelHandlerContext ctx,
Object msg) |
void |
AbstractTrafficShapingHandler.channelRead(ChannelHandlerContext ctx,
Object msg) |
void |
AbstractTrafficShapingHandler.channelRegistered(ChannelHandlerContext ctx) |
protected long |
GlobalChannelTrafficShapingHandler.checkWaitReadTime(ChannelHandlerContext ctx,
long wait,
long now) |
void |
GlobalTrafficShapingHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
ChannelTrafficShapingHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
GlobalChannelTrafficShapingHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
GlobalTrafficShapingHandler.handlerRemoved(ChannelHandlerContext ctx) |
void |
ChannelTrafficShapingHandler.handlerRemoved(ChannelHandlerContext ctx) |
void |
GlobalChannelTrafficShapingHandler.handlerRemoved(ChannelHandlerContext ctx) |
protected void |
GlobalChannelTrafficShapingHandler.informReadOperation(ChannelHandlerContext ctx,
long now) |
protected static boolean |
AbstractTrafficShapingHandler.isHandlerActive(ChannelHandlerContext ctx) |
void |
AbstractTrafficShapingHandler.read(ChannelHandlerContext ctx) |
protected void |
AbstractTrafficShapingHandler.submitWrite(ChannelHandlerContext ctx,
Object msg,
long delay,
ChannelPromise promise)
Deprecated.
|
protected void |
GlobalChannelTrafficShapingHandler.submitWrite(ChannelHandlerContext ctx,
Object msg,
long size,
long writedelay,
long now,
ChannelPromise promise) |
void |
GlobalChannelTrafficShapingHandler.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise) |
void |
AbstractTrafficShapingHandler.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise) |
Copyright © 2008–2015 The Netty Project. All rights reserved.