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.
|
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 a
Serializable object into a byte buffer and
vice versa. |
io.netty.handler.codec.smtp |
SMTP codec.
|
io.netty.handler.codec.stomp |
STOMP codec
|
io.netty.handler.codec.string | |
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.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 |
DefaultChannelPipeline.context(ChannelHandler handler) |
ChannelHandlerContext |
ChannelPipeline.context(Class<? extends ChannelHandler> handlerType)
Returns the context object of the
ChannelHandler of the
specified type in this pipeline. |
ChannelHandlerContext |
DefaultChannelPipeline.context(Class<? extends ChannelHandler> handlerType) |
ChannelHandlerContext |
ChannelPipeline.context(String name)
Returns the context object of the
ChannelHandler with the
specified name in this pipeline. |
ChannelHandlerContext |
DefaultChannelPipeline.context(String name) |
ChannelHandlerContext |
ChannelHandlerContext.fireChannelActive() |
ChannelHandlerContext |
ChannelHandlerContext.fireChannelInactive() |
ChannelHandlerContext |
ChannelHandlerContext.fireChannelRead(Object msg) |
ChannelHandlerContext |
ChannelHandlerContext.fireChannelReadComplete() |
ChannelHandlerContext |
ChannelHandlerContext.fireChannelRegistered() |
ChannelHandlerContext |
ChannelHandlerContext.fireChannelUnregistered() |
ChannelHandlerContext |
ChannelHandlerContext.fireChannelWritabilityChanged() |
ChannelHandlerContext |
ChannelHandlerContext.fireExceptionCaught(Throwable cause) |
ChannelHandlerContext |
ChannelHandlerContext.fireUserEventTriggered(Object evt) |
ChannelHandlerContext |
ChannelPipeline.firstContext()
Returns the context of the first
ChannelHandler in this pipeline. |
ChannelHandlerContext |
DefaultChannelPipeline.firstContext() |
ChannelHandlerContext |
ChannelHandlerContext.flush() |
ChannelHandlerContext |
ChannelPipeline.lastContext()
Returns the context of the last
ChannelHandler in this pipeline. |
ChannelHandlerContext |
DefaultChannelPipeline.lastContext() |
ChannelHandlerContext |
ChannelHandlerContext.read() |
Modifier and Type | Method and Description |
---|---|
void |
ChannelOutboundHandlerAdapter.bind(ChannelHandlerContext ctx,
SocketAddress localAddress,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.bind(SocketAddress, ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
ChannelDuplexHandler.bind(ChannelHandlerContext ctx,
SocketAddress localAddress,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.bind(SocketAddress, ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
CombinedChannelDuplexHandler.bind(ChannelHandlerContext ctx,
SocketAddress localAddress,
ChannelPromise promise) |
void |
ChannelOutboundHandler.bind(ChannelHandlerContext ctx,
SocketAddress localAddress,
ChannelPromise promise)
Called once a bind operation is made.
|
void |
ChannelInboundHandlerAdapter.channelActive(ChannelHandlerContext ctx)
|
void |
ChannelInboundHandler.channelActive(ChannelHandlerContext ctx)
The
Channel of the ChannelHandlerContext is now active |
void |
CombinedChannelDuplexHandler.channelActive(ChannelHandlerContext ctx) |
void |
ChannelInboundHandlerAdapter.channelInactive(ChannelHandlerContext ctx)
|
void |
ChannelInboundHandler.channelInactive(ChannelHandlerContext ctx)
The
Channel of the ChannelHandlerContext was registered is now inactive and reached its
end of lifetime. |
void |
CombinedChannelDuplexHandler.channelInactive(ChannelHandlerContext ctx) |
void |
ChannelInboundHandlerAdapter.channelRead(ChannelHandlerContext ctx,
Object msg)
|
void |
ChannelInboundHandler.channelRead(ChannelHandlerContext ctx,
Object msg)
Invoked when the current
Channel has read a message from the peer. |
void |
SimpleChannelInboundHandler.channelRead(ChannelHandlerContext ctx,
Object msg) |
void |
CombinedChannelDuplexHandler.channelRead(ChannelHandlerContext ctx,
Object msg) |
protected abstract void |
SimpleChannelInboundHandler.channelRead0(ChannelHandlerContext ctx,
I msg)
Please keep in mind that this method will be renamed to
messageReceived(ChannelHandlerContext, I) in 5.0.
Is called for each message of type I . |
void |
ChannelInboundHandlerAdapter.channelReadComplete(ChannelHandlerContext ctx)
Calls
fireChannelReadComplete() to forward
to the next ChannelInboundHandler in the ChannelPipeline . |
void |
ChannelInboundHandler.channelReadComplete(ChannelHandlerContext ctx)
Invoked when the last message read by the current read operation has been consumed by
ChannelInboundHandler.channelRead(ChannelHandlerContext, Object) . |
void |
CombinedChannelDuplexHandler.channelReadComplete(ChannelHandlerContext ctx) |
void |
ChannelInboundHandlerAdapter.channelRegistered(ChannelHandlerContext ctx)
|
void |
ChannelInboundHandler.channelRegistered(ChannelHandlerContext ctx)
|
void |
ChannelInitializer.channelRegistered(ChannelHandlerContext ctx) |
void |
CombinedChannelDuplexHandler.channelRegistered(ChannelHandlerContext ctx) |
void |
ChannelInboundHandlerAdapter.channelUnregistered(ChannelHandlerContext ctx)
Calls
fireChannelUnregistered() to forward
to the next ChannelInboundHandler in the ChannelPipeline . |
void |
ChannelInboundHandler.channelUnregistered(ChannelHandlerContext ctx)
|
void |
CombinedChannelDuplexHandler.channelUnregistered(ChannelHandlerContext ctx) |
void |
ChannelInboundHandlerAdapter.channelWritabilityChanged(ChannelHandlerContext ctx)
Calls
fireChannelWritabilityChanged() to forward
to the next ChannelInboundHandler in the ChannelPipeline . |
void |
ChannelInboundHandler.channelWritabilityChanged(ChannelHandlerContext ctx)
Gets called once the writable state of a
Channel changed. |
void |
CombinedChannelDuplexHandler.channelWritabilityChanged(ChannelHandlerContext ctx) |
void |
ChannelOutboundHandlerAdapter.close(ChannelHandlerContext ctx,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.close(ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
ChannelDuplexHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.close(ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
CombinedChannelDuplexHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
ChannelOutboundHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise)
Called once a close operation is made.
|
void |
ChannelOutboundHandlerAdapter.connect(ChannelHandlerContext ctx,
SocketAddress remoteAddress,
SocketAddress localAddress,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.connect(SocketAddress, SocketAddress, ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
ChannelDuplexHandler.connect(ChannelHandlerContext ctx,
SocketAddress remoteAddress,
SocketAddress localAddress,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.connect(SocketAddress, SocketAddress, ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
CombinedChannelDuplexHandler.connect(ChannelHandlerContext ctx,
SocketAddress remoteAddress,
SocketAddress localAddress,
ChannelPromise promise) |
void |
ChannelOutboundHandler.connect(ChannelHandlerContext ctx,
SocketAddress remoteAddress,
SocketAddress localAddress,
ChannelPromise promise)
Called once a connect operation is made.
|
void |
ChannelOutboundHandlerAdapter.deregister(ChannelHandlerContext ctx,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.deregister(ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
ChannelDuplexHandler.deregister(ChannelHandlerContext ctx,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.close(ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
CombinedChannelDuplexHandler.deregister(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
ChannelOutboundHandler.deregister(ChannelHandlerContext ctx,
ChannelPromise promise)
Called once a deregister operation is made from the current registered
EventLoop . |
void |
ChannelOutboundHandlerAdapter.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.disconnect(ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
ChannelDuplexHandler.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.disconnect(ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
CombinedChannelDuplexHandler.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
ChannelOutboundHandler.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise)
Called once a disconnect operation is made.
|
void |
ChannelHandlerAdapter.exceptionCaught(ChannelHandlerContext ctx,
Throwable cause)
|
void |
ChannelHandler.exceptionCaught(ChannelHandlerContext ctx,
Throwable cause)
Deprecated.
is part of
ChannelInboundHandler |
void |
ChannelInboundHandlerAdapter.exceptionCaught(ChannelHandlerContext ctx,
Throwable cause)
|
void |
ChannelInboundHandler.exceptionCaught(ChannelHandlerContext ctx,
Throwable cause)
Gets called if a
Throwable was thrown. |
void |
ChannelInitializer.exceptionCaught(ChannelHandlerContext ctx,
Throwable cause)
|
void |
CombinedChannelDuplexHandler.exceptionCaught(ChannelHandlerContext ctx,
Throwable cause) |
void |
ChannelOutboundHandlerAdapter.flush(ChannelHandlerContext ctx)
|
void |
ChannelDuplexHandler.flush(ChannelHandlerContext ctx)
|
void |
CombinedChannelDuplexHandler.flush(ChannelHandlerContext ctx) |
void |
ChannelOutboundHandler.flush(ChannelHandlerContext ctx)
Called once a flush operation is made.
|
void |
ChannelHandlerAdapter.handlerAdded(ChannelHandlerContext ctx)
Do nothing by default, sub-classes may override this method.
|
void |
ChannelHandler.handlerAdded(ChannelHandlerContext ctx)
Gets called after the
ChannelHandler was added to the actual context and it's ready to handle events. |
void |
ChannelInitializer.handlerAdded(ChannelHandlerContext ctx)
Do nothing by default, sub-classes may override this method.
|
void |
CombinedChannelDuplexHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
ChannelHandlerAdapter.handlerRemoved(ChannelHandlerContext ctx)
Do nothing by default, sub-classes may override this method.
|
void |
ChannelHandler.handlerRemoved(ChannelHandlerContext ctx)
Gets called after the
ChannelHandler was removed from the actual context and it doesn't handle events
anymore. |
void |
CombinedChannelDuplexHandler.handlerRemoved(ChannelHandlerContext ctx) |
void |
ChannelOutboundHandlerAdapter.read(ChannelHandlerContext ctx)
|
void |
ChannelDuplexHandler.read(ChannelHandlerContext ctx)
|
void |
CombinedChannelDuplexHandler.read(ChannelHandlerContext ctx) |
void |
ChannelOutboundHandler.read(ChannelHandlerContext ctx)
Intercepts
read() . |
void |
ChannelInboundHandlerAdapter.userEventTriggered(ChannelHandlerContext ctx,
Object evt)
Calls
fireUserEventTriggered(Object) to forward
to the next ChannelInboundHandler in the ChannelPipeline . |
void |
ChannelInboundHandler.userEventTriggered(ChannelHandlerContext ctx,
Object evt)
Gets called if an user event was triggered.
|
void |
CombinedChannelDuplexHandler.userEventTriggered(ChannelHandlerContext ctx,
Object evt) |
void |
ChannelOutboundHandlerAdapter.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.write(Object, ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
ChannelDuplexHandler.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.write(Object, ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
CombinedChannelDuplexHandler.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise) |
void |
ChannelOutboundHandler.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise)
Called once a write operation is made.
|
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) . |
void |
DatagramPacketEncoder.bind(ChannelHandlerContext ctx,
SocketAddress localAddress,
ChannelPromise promise) |
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 |
DatagramPacketDecoder.channelActive(ChannelHandlerContext ctx) |
void |
MessageAggregator.channelInactive(ChannelHandlerContext ctx) |
void |
DatagramPacketDecoder.channelInactive(ChannelHandlerContext ctx) |
void |
ByteToMessageDecoder.channelInactive(ChannelHandlerContext ctx) |
void |
ByteToMessageCodec.channelInactive(ChannelHandlerContext ctx) |
void |
MessageToMessageDecoder.channelRead(ChannelHandlerContext ctx,
Object msg) |
void |
ByteToMessageDecoder.channelRead(ChannelHandlerContext ctx,
Object msg) |
void |
ByteToMessageCodec.channelRead(ChannelHandlerContext ctx,
Object msg) |
void |
MessageToMessageCodec.channelRead(ChannelHandlerContext ctx,
Object msg) |
void |
MessageAggregator.channelReadComplete(ChannelHandlerContext ctx) |
void |
DatagramPacketDecoder.channelReadComplete(ChannelHandlerContext ctx) |
void |
ByteToMessageDecoder.channelReadComplete(ChannelHandlerContext ctx) |
void |
ByteToMessageCodec.channelReadComplete(ChannelHandlerContext ctx) |
void |
DatagramPacketDecoder.channelRegistered(ChannelHandlerContext ctx) |
void |
DatagramPacketDecoder.channelUnregistered(ChannelHandlerContext ctx) |
void |
DatagramPacketDecoder.channelWritabilityChanged(ChannelHandlerContext ctx) |
void |
DatagramPacketEncoder.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
DatagramPacketEncoder.connect(ChannelHandlerContext ctx,
SocketAddress remoteAddress,
SocketAddress localAddress,
ChannelPromise promise) |
protected Object |
DelimiterBasedFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf buffer)
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 |
FixedLengthFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in)
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 |
DelimiterBasedFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
LineBasedFrameDecoder.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 abstract void |
ByteToMessageCodec.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
FixedLengthFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
LengthFieldBasedFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
DatagramPacketDecoder.decode(ChannelHandlerContext ctx,
DatagramPacket msg,
List<Object> out) |
protected void |
MessageAggregator.decode(ChannelHandlerContext ctx,
I msg,
List<Object> out) |
protected abstract void |
MessageToMessageDecoder.decode(ChannelHandlerContext ctx,
I msg,
List<Object> out)
Decode from one message to an other.
|
protected abstract void |
MessageToMessageCodec.decode(ChannelHandlerContext ctx,
INBOUND_IN msg,
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 |
ByteToMessageCodec.decodeLast(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
void |
DatagramPacketEncoder.deregister(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
DatagramPacketEncoder.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise) |
protected void |
DatagramPacketEncoder.encode(ChannelHandlerContext ctx,
AddressedEnvelope<M,InetSocketAddress> msg,
List<Object> out) |
protected void |
LengthFieldPrepender.encode(ChannelHandlerContext ctx,
ByteBuf msg,
List<Object> out) |
protected abstract void |
ByteToMessageCodec.encode(ChannelHandlerContext ctx,
I msg,
ByteBuf out) |
protected abstract void |
MessageToByteEncoder.encode(ChannelHandlerContext ctx,
I msg,
ByteBuf out)
Encode a message into a
ByteBuf . |
protected abstract void |
MessageToMessageEncoder.encode(ChannelHandlerContext ctx,
I msg,
List<Object> out)
Encode from one message to an other.
|
protected abstract void |
MessageToMessageCodec.encode(ChannelHandlerContext ctx,
OUTBOUND_IN msg,
List<Object> out) |
void |
DatagramPacketDecoder.exceptionCaught(ChannelHandlerContext ctx,
Throwable cause) |
void |
DatagramPacketEncoder.exceptionCaught(ChannelHandlerContext ctx,
Throwable cause) |
protected ByteBuf |
LengthFieldBasedFrameDecoder.extractFrame(ChannelHandlerContext ctx,
ByteBuf buffer,
int index,
int length)
Extract the sub-region of the specified buffer.
|
void |
DatagramPacketEncoder.flush(ChannelHandlerContext ctx) |
protected void |
MessageAggregator.handleOversizedMessage(ChannelHandlerContext ctx,
S oversized)
Invoked when an incoming request exceeds the maximum content length.
|
void |
MessageAggregator.handlerAdded(ChannelHandlerContext ctx) |
void |
DatagramPacketDecoder.handlerAdded(ChannelHandlerContext ctx) |
void |
DatagramPacketEncoder.handlerAdded(ChannelHandlerContext ctx) |
void |
ByteToMessageCodec.handlerAdded(ChannelHandlerContext ctx) |
void |
MessageAggregator.handlerRemoved(ChannelHandlerContext ctx) |
void |
DatagramPacketDecoder.handlerRemoved(ChannelHandlerContext ctx) |
void |
DatagramPacketEncoder.handlerRemoved(ChannelHandlerContext ctx) |
void |
ByteToMessageDecoder.handlerRemoved(ChannelHandlerContext ctx) |
void |
ByteToMessageCodec.handlerRemoved(ChannelHandlerContext ctx) |
protected void |
ByteToMessageDecoder.handlerRemoved0(ChannelHandlerContext ctx)
Gets called after the
ByteToMessageDecoder was removed from the actual context and it doesn't handle
events anymore. |
void |
DatagramPacketEncoder.read(ChannelHandlerContext ctx) |
void |
DatagramPacketDecoder.userEventTriggered(ChannelHandlerContext ctx,
Object evt) |
void |
ByteToMessageDecoder.userEventTriggered(ChannelHandlerContext ctx,
Object evt) |
void |
MessageToMessageEncoder.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) |
void |
MessageToMessageCodec.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
protected void |
Base64Decoder.decode(ChannelHandlerContext ctx,
ByteBuf msg,
List<Object> out) |
protected void |
Base64Encoder.encode(ChannelHandlerContext ctx,
ByteBuf msg,
List<Object> out) |
Modifier and Type | Method and Description |
---|---|
protected void |
ByteArrayDecoder.decode(ChannelHandlerContext ctx,
ByteBuf msg,
List<Object> out) |
protected void |
ByteArrayEncoder.encode(ChannelHandlerContext ctx,
byte[] msg,
List<Object> out) |
Modifier and Type | Method and Description |
---|---|
protected ByteBuf |
JdkZlibEncoder.allocateBuffer(ChannelHandlerContext ctx,
ByteBuf msg,
boolean preferDirect) |
void |
JZlibEncoder.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
Bzip2Encoder.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
JdkZlibEncoder.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
protected void |
JdkZlibDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
FastLzFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
SnappyFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
Bzip2Decoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
JZlibDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
JZlibEncoder.encode(ChannelHandlerContext ctx,
ByteBuf in,
ByteBuf out) |
protected void |
SnappyFrameEncoder.encode(ChannelHandlerContext ctx,
ByteBuf in,
ByteBuf out) |
protected void |
FastLzFrameEncoder.encode(ChannelHandlerContext ctx,
ByteBuf in,
ByteBuf out) |
protected void |
Bzip2Encoder.encode(ChannelHandlerContext ctx,
ByteBuf in,
ByteBuf out) |
protected void |
JdkZlibEncoder.encode(ChannelHandlerContext ctx,
ByteBuf uncompressed,
ByteBuf out) |
void |
JZlibEncoder.handlerAdded(ChannelHandlerContext ctx) |
void |
Bzip2Encoder.handlerAdded(ChannelHandlerContext ctx) |
void |
JdkZlibEncoder.handlerAdded(ChannelHandlerContext ctx) |
protected void |
JdkZlibDecoder.handlerRemoved0(ChannelHandlerContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected ByteBuf |
DatagramDnsQueryEncoder.allocateBuffer(ChannelHandlerContext ctx,
AddressedEnvelope<DnsQuery,InetSocketAddress> msg)
Allocate a
ByteBuf which will be used for constructing a datagram packet. |
protected ByteBuf |
DatagramDnsResponseEncoder.allocateBuffer(ChannelHandlerContext ctx,
AddressedEnvelope<DnsResponse,InetSocketAddress> msg)
Allocate a
ByteBuf which will be used for constructing a datagram packet. |
protected void |
DatagramDnsQueryDecoder.decode(ChannelHandlerContext ctx,
DatagramPacket packet,
List<Object> out) |
protected void |
DatagramDnsResponseDecoder.decode(ChannelHandlerContext ctx,
DatagramPacket packet,
List<Object> out) |
protected void |
DatagramDnsQueryEncoder.encode(ChannelHandlerContext ctx,
AddressedEnvelope<DnsQuery,InetSocketAddress> in,
List<Object> out) |
protected void |
DatagramDnsResponseEncoder.encode(ChannelHandlerContext ctx,
AddressedEnvelope<DnsResponse,InetSocketAddress> in,
List<Object> out) |
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 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 |
RedisDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
RedisArrayAggregator.decode(ChannelHandlerContext ctx,
RedisMessage msg,
List<Object> out) |
protected void |
RedisEncoder.encode(ChannelHandlerContext ctx,
RedisMessage msg,
List<Object> out) |
Modifier and Type | Method and Description |
---|---|
protected 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) |
Modifier and Type | Method and Description |
---|---|
protected SmtpResponse |
SmtpResponseDecoder.decode(ChannelHandlerContext ctx,
ByteBuf buffer) |
protected void |
SmtpRequestEncoder.encode(ChannelHandlerContext ctx,
Object msg,
List<Object> out) |
Modifier and Type | Method and Description |
---|---|
protected void |
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) |
protected void |
LineEncoder.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 |
---|---|
void |
FlowControlHandler.channelInactive(ChannelHandlerContext ctx) |
void |
FlowControlHandler.channelRead(ChannelHandlerContext ctx,
Object msg) |
void |
FlowControlHandler.channelReadComplete(ChannelHandlerContext ctx) |
void |
FlowControlHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
FlowControlHandler.read(ChannelHandlerContext ctx) |
Modifier and Type | Method and Description |
---|---|
void |
FlushConsolidationHandler.channelRead(ChannelHandlerContext ctx,
Object msg) |
void |
FlushConsolidationHandler.channelReadComplete(ChannelHandlerContext ctx) |
void |
FlushConsolidationHandler.channelWritabilityChanged(ChannelHandlerContext ctx) |
void |
FlushConsolidationHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
FlushConsolidationHandler.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
FlushConsolidationHandler.exceptionCaught(ChannelHandlerContext ctx,
Throwable cause) |
void |
FlushConsolidationHandler.flush(ChannelHandlerContext ctx) |
void |
FlushConsolidationHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
FlushConsolidationHandler.handlerRemoved(ChannelHandlerContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
RuleBasedIpFilter.accept(ChannelHandlerContext ctx,
InetSocketAddress remoteAddress) |
protected boolean |
UniqueIpFilter.accept(ChannelHandlerContext ctx,
InetSocketAddress remoteAddress) |
protected abstract boolean |
AbstractRemoteAddressFilter.accept(ChannelHandlerContext ctx,
T remoteAddress)
This method is called immediately after a
Channel gets registered. |
protected void |
AbstractRemoteAddressFilter.channelAccepted(ChannelHandlerContext ctx,
T remoteAddress)
This method is called if
remoteAddress gets accepted by
AbstractRemoteAddressFilter.accept(ChannelHandlerContext, SocketAddress) . |
void |
AbstractRemoteAddressFilter.channelActive(ChannelHandlerContext ctx) |
void |
AbstractRemoteAddressFilter.channelRegistered(ChannelHandlerContext ctx) |
protected ChannelFuture |
AbstractRemoteAddressFilter.channelRejected(ChannelHandlerContext ctx,
T remoteAddress)
This method is called if
remoteAddress gets rejected by
AbstractRemoteAddressFilter.accept(ChannelHandlerContext, SocketAddress) . |
Modifier and Type | Method and Description |
---|---|
void |
LoggingHandler.bind(ChannelHandlerContext ctx,
SocketAddress localAddress,
ChannelPromise promise) |
void |
LoggingHandler.channelActive(ChannelHandlerContext ctx) |
void |
LoggingHandler.channelInactive(ChannelHandlerContext ctx) |
void |
LoggingHandler.channelRead(ChannelHandlerContext ctx,
Object msg) |
void |
LoggingHandler.channelReadComplete(ChannelHandlerContext ctx) |
void |
LoggingHandler.channelRegistered(ChannelHandlerContext ctx) |
void |
LoggingHandler.channelUnregistered(ChannelHandlerContext ctx) |
void |
LoggingHandler.channelWritabilityChanged(ChannelHandlerContext ctx) |
void |
LoggingHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
LoggingHandler.connect(ChannelHandlerContext ctx,
SocketAddress remoteAddress,
SocketAddress localAddress,
ChannelPromise promise) |
void |
LoggingHandler.deregister(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
LoggingHandler.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
LoggingHandler.exceptionCaught(ChannelHandlerContext ctx,
Throwable cause) |
void |
LoggingHandler.flush(ChannelHandlerContext ctx) |
protected String |
LoggingHandler.format(ChannelHandlerContext ctx,
String eventName)
Formats an event and returns the formatted message.
|
protected String |
LoggingHandler.format(ChannelHandlerContext ctx,
String eventName,
Object arg)
Formats an event and returns the formatted message.
|
protected String |
LoggingHandler.format(ChannelHandlerContext ctx,
String eventName,
Object firstArg,
Object secondArg)
Formats an event and returns the formatted message.
|
void |
LoggingHandler.userEventTriggered(ChannelHandlerContext ctx,
Object evt) |
void |
LoggingHandler.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractSniHandler.bind(ChannelHandlerContext ctx,
SocketAddress localAddress,
ChannelPromise promise) |
void |
SslHandler.bind(ChannelHandlerContext ctx,
SocketAddress localAddress,
ChannelPromise promise) |
void |
SslHandler.channelActive(ChannelHandlerContext ctx)
Issues an initial TLS handshake once connected when used in client-mode
|
void |
SslHandler.channelInactive(ChannelHandlerContext ctx) |
void |
SslHandler.channelReadComplete(ChannelHandlerContext ctx) |
void |
AbstractSniHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
SslHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
protected abstract void |
ApplicationProtocolNegotiationHandler.configurePipeline(ChannelHandlerContext ctx,
String protocol)
Invoked on successful initial SSL/TLS handshake.
|
void |
AbstractSniHandler.connect(ChannelHandlerContext ctx,
SocketAddress remoteAddress,
SocketAddress localAddress,
ChannelPromise promise) |
void |
SslHandler.connect(ChannelHandlerContext ctx,
SocketAddress remoteAddress,
SocketAddress localAddress,
ChannelPromise promise) |
protected void |
AbstractSniHandler.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
OptionalSslHandler.decode(ChannelHandlerContext context,
ByteBuf in,
List<Object> out) |
protected void |
SslHandler.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
void |
AbstractSniHandler.deregister(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
SslHandler.deregister(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
AbstractSniHandler.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
SslHandler.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
ApplicationProtocolNegotiationHandler.exceptionCaught(ChannelHandlerContext ctx,
Throwable cause) |
void |
SslHandler.exceptionCaught(ChannelHandlerContext ctx,
Throwable cause) |
void |
AbstractSniHandler.flush(ChannelHandlerContext ctx) |
void |
SslHandler.flush(ChannelHandlerContext ctx) |
void |
SslHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
SslHandler.handlerRemoved0(ChannelHandlerContext ctx) |
protected void |
ApplicationProtocolNegotiationHandler.handshakeFailure(ChannelHandlerContext ctx,
Throwable cause)
Invoked on failed initial SSL/TLS handshake.
|
protected abstract Future<T> |
AbstractSniHandler.lookup(ChannelHandlerContext ctx,
String hostname)
Kicks off a lookup for the given SNI value and returns a
Future which in turn will
notify the AbstractSniHandler.onLookupComplete(ChannelHandlerContext, String, Future) on completion. |
protected Future<SslContext> |
SniHandler.lookup(ChannelHandlerContext ctx,
String hostname)
The default implementation will simply call
AsyncMapping.map(Object, Promise) but
users can override this method to implement custom behavior. |
protected ChannelHandler |
OptionalSslHandler.newNonSslHandler(ChannelHandlerContext context)
Override to configure the ChannelHandler.
|
protected SslHandler |
OptionalSslHandler.newSslHandler(ChannelHandlerContext context,
SslContext sslContext)
Override to configure the SslHandler eg.
|
protected void |
SniHandler.onLookupComplete(ChannelHandlerContext ctx,
String hostname,
Future<SslContext> future) |
protected abstract void |
AbstractSniHandler.onLookupComplete(ChannelHandlerContext ctx,
String hostname,
Future<T> future)
Called upon completion of the
AbstractSniHandler.lookup(ChannelHandlerContext, String) Future . |
void |
AbstractSniHandler.read(ChannelHandlerContext ctx) |
void |
SslHandler.read(ChannelHandlerContext ctx) |
protected void |
SniHandler.replaceHandler(ChannelHandlerContext ctx,
String hostname,
SslContext sslContext)
The default implementation of this method will simply replace
this SniHandler
instance with a SslHandler . |
void |
ApplicationProtocolNegotiationHandler.userEventTriggered(ChannelHandlerContext ctx,
Object evt) |
void |
AbstractSniHandler.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise) |
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 |
ChunkedNioFile.readChunk(ChannelHandlerContext ctx)
Deprecated.
|
ByteBuf |
ChunkedStream.readChunk(ChannelHandlerContext ctx)
Deprecated.
|
ByteBuf |
ChunkedNioStream.readChunk(ChannelHandlerContext ctx)
Deprecated.
|
ByteBuf |
ChunkedFile.readChunk(ChannelHandlerContext ctx)
Deprecated.
|
B |
ChunkedInput.readChunk(ChannelHandlerContext ctx)
Deprecated.
Use
ChunkedInput.readChunk(ByteBufAllocator) .
Fetches a chunked data from the stream. Once this method returns the last chunk
and thus the stream has reached at its end, any subsequent |
void |
ChunkedWriteHandler.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
void |
IdleStateHandler.channelActive(ChannelHandlerContext ctx) |
protected void |
ReadTimeoutHandler.channelIdle(ChannelHandlerContext ctx,
IdleStateEvent evt) |
protected void |
IdleStateHandler.channelIdle(ChannelHandlerContext ctx,
IdleStateEvent evt)
Is called when an
IdleStateEvent should be fired. |
void |
IdleStateHandler.channelInactive(ChannelHandlerContext ctx) |
void |
IdleStateHandler.channelRead(ChannelHandlerContext ctx,
Object msg) |
void |
IdleStateHandler.channelReadComplete(ChannelHandlerContext ctx) |
void |
IdleStateHandler.channelRegistered(ChannelHandlerContext ctx) |
void |
IdleStateHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
WriteTimeoutHandler.handlerRemoved(ChannelHandlerContext ctx) |
void |
IdleStateHandler.handlerRemoved(ChannelHandlerContext ctx) |
protected void |
ReadTimeoutHandler.readTimedOut(ChannelHandlerContext ctx)
Is called when a read timeout was detected.
|
void |
WriteTimeoutHandler.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise) |
void |
IdleStateHandler.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise) |
protected void |
WriteTimeoutHandler.writeTimedOut(ChannelHandlerContext ctx)
Is called when a write timeout was detected
|
Modifier and Type | Method and Description |
---|---|
void |
GlobalChannelTrafficShapingHandler.channelRead(ChannelHandlerContext ctx,
Object msg) |
void |
AbstractTrafficShapingHandler.channelRead(ChannelHandlerContext ctx,
Object msg) |
void |
AbstractTrafficShapingHandler.channelRegistered(ChannelHandlerContext ctx) |
protected long |
GlobalChannelTrafficShapingHandler.checkWaitReadTime(ChannelHandlerContext ctx,
long wait,
long now) |
void |
GlobalTrafficShapingHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
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-2017 The Netty Project. All Rights Reserved.