| 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.http |
Encoder, decoder and their related message types for HTTP.
|
| 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.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.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.socks |
Encoder, decoder and their related message types for Socks.
|
| io.netty.handler.codec.spdy |
Encoder, decoder, session handler and their related message types for the SPDY protocol.
|
| io.netty.handler.codec.string | |
| io.netty.handler.codec.xml |
Xml specific codecs.
|
| 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 |
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.channelWritabilityChanged(ChannelHandlerContext)
event to the next ChannelHandler in the ChannelPipeline. |
ChannelHandlerContext |
ChannelHandlerContext.fireChannelRegistered()
|
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 |
SimpleChannelInboundHandler.channelRead(ChannelHandlerContext ctx,
Object msg) |
void |
ChannelHandler.channelRead(ChannelHandlerContext ctx,
Object msg)
Invoked when the current
Channel has read a message from the peer. |
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 |
ChannelInitializer.channelRegistered(ChannelHandlerContext ctx) |
void |
ChannelHandler.channelRegistered(ChannelHandlerContext ctx)
|
void |
ChannelHandlerAdapter.channelRegistered(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.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 |
ChannelHandlerAppender.handlerAdded(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 |
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 |
DefaultChannelHandlerInvoker.invokeBind(ChannelHandlerContext ctx,
SocketAddress localAddress,
ChannelPromise promise) |
void |
ChannelHandlerInvoker.invokeBind(ChannelHandlerContext ctx,
SocketAddress localAddress,
ChannelPromise promise)
|
static void |
ChannelHandlerInvokerUtil.invokeBindNow(ChannelHandlerContext ctx,
SocketAddress localAddress,
ChannelPromise promise) |
void |
DefaultChannelHandlerInvoker.invokeChannelActive(ChannelHandlerContext ctx) |
void |
ChannelHandlerInvoker.invokeChannelActive(ChannelHandlerContext ctx)
|
static void |
ChannelHandlerInvokerUtil.invokeChannelActiveNow(ChannelHandlerContext ctx) |
void |
DefaultChannelHandlerInvoker.invokeChannelInactive(ChannelHandlerContext ctx) |
void |
ChannelHandlerInvoker.invokeChannelInactive(ChannelHandlerContext ctx)
|
static void |
ChannelHandlerInvokerUtil.invokeChannelInactiveNow(ChannelHandlerContext ctx) |
void |
DefaultChannelHandlerInvoker.invokeChannelRead(ChannelHandlerContext ctx,
Object msg) |
void |
ChannelHandlerInvoker.invokeChannelRead(ChannelHandlerContext ctx,
Object msg)
|
void |
DefaultChannelHandlerInvoker.invokeChannelReadComplete(ChannelHandlerContext ctx) |
void |
ChannelHandlerInvoker.invokeChannelReadComplete(ChannelHandlerContext ctx)
|
static void |
ChannelHandlerInvokerUtil.invokeChannelReadCompleteNow(ChannelHandlerContext ctx) |
static void |
ChannelHandlerInvokerUtil.invokeChannelReadNow(ChannelHandlerContext ctx,
Object msg) |
void |
DefaultChannelHandlerInvoker.invokeChannelRegistered(ChannelHandlerContext ctx) |
void |
ChannelHandlerInvoker.invokeChannelRegistered(ChannelHandlerContext ctx)
|
static void |
ChannelHandlerInvokerUtil.invokeChannelRegisteredNow(ChannelHandlerContext ctx) |
void |
DefaultChannelHandlerInvoker.invokeChannelWritabilityChanged(ChannelHandlerContext ctx) |
void |
ChannelHandlerInvoker.invokeChannelWritabilityChanged(ChannelHandlerContext ctx)
|
static void |
ChannelHandlerInvokerUtil.invokeChannelWritabilityChangedNow(ChannelHandlerContext ctx) |
void |
DefaultChannelHandlerInvoker.invokeClose(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
ChannelHandlerInvoker.invokeClose(ChannelHandlerContext ctx,
ChannelPromise promise)
|
static void |
ChannelHandlerInvokerUtil.invokeCloseNow(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
DefaultChannelHandlerInvoker.invokeConnect(ChannelHandlerContext ctx,
SocketAddress remoteAddress,
SocketAddress localAddress,
ChannelPromise promise) |
void |
ChannelHandlerInvoker.invokeConnect(ChannelHandlerContext ctx,
SocketAddress remoteAddress,
SocketAddress localAddress,
ChannelPromise promise)
|
static void |
ChannelHandlerInvokerUtil.invokeConnectNow(ChannelHandlerContext ctx,
SocketAddress remoteAddress,
SocketAddress localAddress,
ChannelPromise promise) |
void |
DefaultChannelHandlerInvoker.invokeDisconnect(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
ChannelHandlerInvoker.invokeDisconnect(ChannelHandlerContext ctx,
ChannelPromise promise)
|
static void |
ChannelHandlerInvokerUtil.invokeDisconnectNow(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
DefaultChannelHandlerInvoker.invokeExceptionCaught(ChannelHandlerContext ctx,
Throwable cause) |
void |
ChannelHandlerInvoker.invokeExceptionCaught(ChannelHandlerContext ctx,
Throwable cause)
|
static void |
ChannelHandlerInvokerUtil.invokeExceptionCaughtNow(ChannelHandlerContext ctx,
Throwable cause) |
void |
DefaultChannelHandlerInvoker.invokeFlush(ChannelHandlerContext ctx) |
void |
ChannelHandlerInvoker.invokeFlush(ChannelHandlerContext ctx)
|
static void |
ChannelHandlerInvokerUtil.invokeFlushNow(ChannelHandlerContext ctx) |
void |
DefaultChannelHandlerInvoker.invokeRead(ChannelHandlerContext ctx) |
void |
ChannelHandlerInvoker.invokeRead(ChannelHandlerContext ctx)
|
static void |
ChannelHandlerInvokerUtil.invokeReadNow(ChannelHandlerContext ctx) |
void |
DefaultChannelHandlerInvoker.invokeUserEventTriggered(ChannelHandlerContext ctx,
Object event) |
void |
ChannelHandlerInvoker.invokeUserEventTriggered(ChannelHandlerContext ctx,
Object event)
|
static void |
ChannelHandlerInvokerUtil.invokeUserEventTriggeredNow(ChannelHandlerContext ctx,
Object event) |
void |
DefaultChannelHandlerInvoker.invokeWrite(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise) |
void |
ChannelHandlerInvoker.invokeWrite(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise)
|
static void |
ChannelHandlerInvokerUtil.invokeWriteAndFlushNow(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)
|
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)
|
| Modifier and Type | Method and Description |
|---|---|
protected void |
ByteToMessageDecoder.callDecode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out)
Called once data should be decoded from the given
ByteBuf. |
protected void |
ReplayingDecoder.callDecode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
void |
ByteToMessageDecoder.channelInactive(ChannelHandlerContext ctx) |
void |
ReplayingDecoder.channelInactive(ChannelHandlerContext ctx) |
void |
ByteToMessageDecoder.channelRead(ChannelHandlerContext ctx,
Object msg) |
void |
MessageToMessageCodec.channelRead(ChannelHandlerContext ctx,
Object msg) |
void |
ByteToMessageCodec.channelRead(ChannelHandlerContext ctx,
Object msg) |
void |
MessageToMessageDecoder.channelRead(ChannelHandlerContext ctx,
Object msg) |
void |
ByteToMessageDecoder.channelReadComplete(ChannelHandlerContext ctx) |
protected Object |
DelimiterBasedFrameDecoder.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 Object |
LineBasedFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf buffer)
Create a frame out of the
ByteBuf and return it. |
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 |
DelimiterBasedFrameDecoder.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 |
LineBasedFrameDecoder.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 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) |
protected void |
LengthFieldPrepender.encode(ChannelHandlerContext ctx,
ByteBuf msg,
List<Object> out) |
protected abstract void |
MessageToByteEncoder.encode(ChannelHandlerContext ctx,
I msg,
ByteBuf out)
Encode a message into a
ByteBuf. |
protected abstract void |
ByteToMessageCodec.encode(ChannelHandlerContext ctx,
I msg,
ByteBuf out) |
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.
|
void |
ByteToMessageDecoder.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 |
MessageToByteEncoder.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 |
MessageToMessageEncoder.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 |
|---|---|
void |
JZlibEncoder.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 |
SnappyFramedDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
JZlibDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
SnappyFramedEncoder.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) |
void |
JZlibEncoder.handlerAdded(ChannelHandlerContext ctx) |
void |
JdkZlibEncoder.handlerAdded(ChannelHandlerContext ctx) |
protected void |
JdkZlibDecoder.handlerRemoved0(ChannelHandlerContext ctx) |
| Modifier and Type | Method and Description |
|---|---|
void |
HttpContentDecoder.channelInactive(ChannelHandlerContext ctx) |
void |
HttpObjectAggregator.channelInactive(ChannelHandlerContext ctx) |
void |
HttpContentEncoder.channelInactive(ChannelHandlerContext ctx) |
protected void |
HttpObjectDecoder.decode(ChannelHandlerContext ctx,
ByteBuf buffer,
List<Object> out) |
protected void |
HttpContentDecoder.decode(ChannelHandlerContext ctx,
HttpObject msg,
List<Object> out) |
protected void |
HttpObjectAggregator.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) |
void |
HttpObjectAggregator.handlerAdded(ChannelHandlerContext ctx) |
void |
HttpContentDecoder.handlerRemoved(ChannelHandlerContext ctx) |
void |
HttpObjectAggregator.handlerRemoved(ChannelHandlerContext ctx) |
void |
HttpContentEncoder.handlerRemoved(ChannelHandlerContext ctx) |
| Modifier and Type | Method and Description |
|---|---|
HttpContent |
HttpPostRequestEncoder.readChunk(ChannelHandlerContext ctx)
Returns the next available HttpChunk.
|
| Modifier and Type | Method and Description |
|---|---|
void |
WebSocketFrameAggregator.channelInactive(ChannelHandlerContext ctx) |
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 |
WebSocketClientProtocolHandler.decode(ChannelHandlerContext ctx,
WebSocketFrame frame,
List<Object> out) |
protected void |
WebSocketFrameAggregator.decode(ChannelHandlerContext ctx,
WebSocketFrame msg,
List<Object> out) |
protected void |
WebSocketServerProtocolHandler.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 |
WebSocketClientProtocolHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
WebSocketServerProtocolHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
WebSocketFrameAggregator.handlerRemoved(ChannelHandlerContext ctx) |
| 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 |
DefaultMarshallerProvider.getMarshaller(ChannelHandlerContext ctx) |
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.Unmarshaller |
DefaultUnmarshallerProvider.getUnmarshaller(ChannelHandlerContext ctx) |
org.jboss.marshalling.Unmarshaller |
UnmarshallerProvider.getUnmarshaller(ChannelHandlerContext ctx)
Get the
Unmarshaller for the given ChannelHandlerContext |
org.jboss.marshalling.Unmarshaller |
ThreadLocalUnmarshallerProvider.getUnmarshaller(ChannelHandlerContext ctx) |
org.jboss.marshalling.Unmarshaller |
ContextBoundUnmarshallerProvider.getUnmarshaller(ChannelHandlerContext ctx) |
| Modifier and Type | Field and Description |
|---|---|
protected ChannelHandlerContext |
AbstractMemcacheObjectAggregator.ctx
Holds the current channel handler context if set.
|
| Modifier and Type | Method and Description |
|---|---|
void |
AbstractMemcacheObjectAggregator.channelInactive(ChannelHandlerContext ctx) |
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. |
void |
AbstractMemcacheObjectAggregator.handlerAdded(ChannelHandlerContext ctx) |
void |
AbstractMemcacheObjectAggregator.handlerRemoved(ChannelHandlerContext ctx) |
| 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 void |
BinaryMemcacheObjectAggregator.decode(ChannelHandlerContext ctx,
MemcacheObject msg,
List<Object> out) |
protected ByteBuf |
AbstractBinaryMemcacheEncoder.encodeMessage(ChannelHandlerContext ctx,
M msg) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
ProtobufDecoder.decode(ChannelHandlerContext ctx,
ByteBuf msg,
List<Object> out) |
protected void |
ProtobufVarint32FrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
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 |
SctpMessageCompletionHandler.decode(ChannelHandlerContext ctx,
SctpMessage msg,
List<Object> out) |
protected void |
SctpInboundByteStreamHandler.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 |
CompatibleObjectEncoder.encode(ChannelHandlerContext ctx,
Serializable msg,
ByteBuf out) |
protected void |
ObjectEncoder.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 |
SocksInitResponseDecoder.decode(ChannelHandlerContext ctx,
ByteBuf byteBuf,
List<Object> out) |
protected void |
SocksCmdResponseDecoder.decode(ChannelHandlerContext ctx,
ByteBuf byteBuf,
List<Object> out) |
protected void |
SocksCmdRequestDecoder.decode(ChannelHandlerContext ctx,
ByteBuf byteBuf,
List<Object> out) |
protected void |
SocksAuthRequestDecoder.decode(ChannelHandlerContext ctx,
ByteBuf byteBuf,
List<Object> out) |
protected void |
SocksAuthResponseDecoder.decode(ChannelHandlerContext channelHandlerContext,
ByteBuf byteBuf,
List<Object> out) |
protected void |
SocksInitRequestDecoder.decode(ChannelHandlerContext ctx,
ByteBuf byteBuf,
List<Object> out) |
protected void |
SocksMessageEncoder.encode(ChannelHandlerContext ctx,
SocksMessage 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 |
SpdyOrHttpChooser.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
SpdyFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf buffer,
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) |
void |
SpdyFrameDecoder.decodeLast(ChannelHandlerContext ctx,
ByteBuf in,
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) |
protected void |
SpdyFrameEncoder.encode(ChannelHandlerContext ctx,
SpdyFrame msg,
ByteBuf out) |
ByteBuf |
SpdyHeaderBlockRawEncoder.encode(ChannelHandlerContext ctx,
SpdyHeadersFrame frame) |
void |
SpdySessionHandler.exceptionCaught(ChannelHandlerContext ctx,
Throwable cause) |
void |
SpdyFrameEncoder.handlerAdded(ChannelHandlerContext ctx) |
void |
SpdySessionHandler.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise) |
| 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 |
|---|---|
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.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
LoggingHandler.connect(ChannelHandlerContext ctx,
SocketAddress remoteAddress,
SocketAddress localAddress,
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 |
ChunkedWriteHandler.channelInactive(ChannelHandlerContext ctx) |
void |
ChunkedWriteHandler.channelWritabilityChanged(ChannelHandlerContext ctx) |
void |
ChunkedWriteHandler.flush(ChannelHandlerContext ctx) |
void |
ChunkedWriteHandler.handlerAdded(ChannelHandlerContext ctx) |
ByteBuf |
ChunkedFile.readChunk(ChannelHandlerContext ctx) |
B |
ChunkedInput.readChunk(ChannelHandlerContext ctx)
Fetches a chunked data from the stream.
|
ByteBuf |
ChunkedNioFile.readChunk(ChannelHandlerContext ctx) |
ByteBuf |
ChunkedNioStream.readChunk(ChannelHandlerContext ctx) |
ByteBuf |
ChunkedStream.readChunk(ChannelHandlerContext ctx) |
void |
ChunkedWriteHandler.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise) |
| Modifier and Type | Method and Description |
|---|---|
void |
IdleStateHandler.channelActive(ChannelHandlerContext ctx) |
void |
ReadTimeoutHandler.channelActive(ChannelHandlerContext ctx) |
protected void |
IdleStateHandler.channelIdle(ChannelHandlerContext ctx,
IdleStateEvent evt)
Is called when an
IdleStateEvent should be fired. |
void |
IdleStateHandler.channelInactive(ChannelHandlerContext ctx) |
void |
ReadTimeoutHandler.channelInactive(ChannelHandlerContext ctx) |
void |
IdleStateHandler.channelRead(ChannelHandlerContext ctx,
Object msg) |
void |
ReadTimeoutHandler.channelRead(ChannelHandlerContext ctx,
Object msg) |
void |
IdleStateHandler.channelRegistered(ChannelHandlerContext ctx) |
void |
ReadTimeoutHandler.channelRegistered(ChannelHandlerContext ctx) |
void |
IdleStateHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
ReadTimeoutHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
IdleStateHandler.handlerRemoved(ChannelHandlerContext ctx) |
void |
ReadTimeoutHandler.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 |
AbstractTrafficShapingHandler.channelRead(ChannelHandlerContext ctx,
Object msg) |
void |
ChannelTrafficShapingHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
ChannelTrafficShapingHandler.handlerRemoved(ChannelHandlerContext ctx) |
void |
AbstractTrafficShapingHandler.read(ChannelHandlerContext ctx) |
void |
AbstractTrafficShapingHandler.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise) |
Copyright © 2008–2013 The Netty Project. All rights reserved.