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.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.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.logging |
Logs a
io.netty.channel.ChannelEvent 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
ChannelInboundHandler.channelReadComplete(ChannelHandlerContext)
event to the next ChannelInboundHandler in the ChannelPipeline . |
ChannelHandlerContext |
ChannelHandlerContext.fireChannelRegistered()
|
ChannelHandlerContext |
ChannelHandlerContext.fireChannelUnregistered()
|
ChannelHandlerContext |
ChannelHandlerContext.fireChannelWritabilityChanged()
Triggers an
ChannelInboundHandler.channelWritabilityChanged(ChannelHandlerContext)
event to the next ChannelInboundHandler 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
ChannelInboundHandler.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 |
ChannelOutboundHandlerAdapter.bind(ChannelHandlerContext ctx,
SocketAddress localAddress,
ChannelPromise promise)
Calls
bind(SocketAddress, ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
CombinedChannelDuplexHandler.bind(ChannelHandlerContext ctx,
SocketAddress localAddress,
ChannelPromise promise) |
void |
ChannelDuplexHandler.bind(ChannelHandlerContext ctx,
SocketAddress localAddress,
ChannelPromise future)
Calls
bind(SocketAddress, ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
ChannelOutboundHandler.bind(ChannelHandlerContext ctx,
SocketAddress localAddress,
ChannelPromise promise)
Called once a bind operation is made.
|
void |
ChannelInboundHandler.channelActive(ChannelHandlerContext ctx)
The
Channel of the ChannelHandlerContext is now active |
void |
CombinedChannelDuplexHandler.channelActive(ChannelHandlerContext ctx) |
void |
ChannelInboundHandlerAdapter.channelActive(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.channelInactive(ChannelHandlerContext ctx)
|
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) |
void |
ChannelInboundHandlerAdapter.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. |
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.channelReadComplete(ChannelHandlerContext ctx)
Calls
fireChannelReadComplete() to forward
to the next ChannelInboundHandler in the ChannelPipeline . |
void |
ChannelInboundHandler.channelRegistered(ChannelHandlerContext ctx)
|
void |
CombinedChannelDuplexHandler.channelRegistered(ChannelHandlerContext ctx) |
void |
ChannelInitializer.channelRegistered(ChannelHandlerContext ctx) |
void |
ChannelInboundHandlerAdapter.channelRegistered(ChannelHandlerContext ctx)
|
void |
ChannelInboundHandler.channelUnregistered(ChannelHandlerContext ctx)
|
void |
CombinedChannelDuplexHandler.channelUnregistered(ChannelHandlerContext ctx) |
void |
ChannelInboundHandlerAdapter.channelUnregistered(ChannelHandlerContext ctx)
Calls
fireChannelUnregistered() 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 |
ChannelInboundHandlerAdapter.channelWritabilityChanged(ChannelHandlerContext ctx)
Calls
fireChannelWritabilityChanged() to forward
to the next ChannelInboundHandler in the ChannelPipeline . |
void |
ChannelOutboundHandlerAdapter.close(ChannelHandlerContext ctx,
ChannelPromise promise)
|
void |
CombinedChannelDuplexHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
ChannelDuplexHandler.close(ChannelHandlerContext ctx,
ChannelPromise future)
|
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
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 |
ChannelDuplexHandler.connect(ChannelHandlerContext ctx,
SocketAddress remoteAddress,
SocketAddress localAddress,
ChannelPromise future)
Calls
connect(SocketAddress, SocketAddress, ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
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)
|
void |
CombinedChannelDuplexHandler.deregister(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
ChannelDuplexHandler.deregister(ChannelHandlerContext ctx,
ChannelPromise future)
|
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
disconnect(ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
CombinedChannelDuplexHandler.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
ChannelDuplexHandler.disconnect(ChannelHandlerContext ctx,
ChannelPromise future)
Calls
disconnect(ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
ChannelOutboundHandler.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise)
Called once a disconnect operation is made.
|
void |
ChannelInboundHandler.exceptionCaught(ChannelHandlerContext ctx,
Throwable cause)
Gets called if a
Throwable was thrown. |
void |
ChannelHandler.exceptionCaught(ChannelHandlerContext ctx,
Throwable cause)
Gets called if a
Throwable was thrown. |
void |
CombinedChannelDuplexHandler.exceptionCaught(ChannelHandlerContext ctx,
Throwable cause) |
void |
ChannelHandlerAdapter.exceptionCaught(ChannelHandlerContext ctx,
Throwable cause)
|
void |
ChannelInboundHandlerAdapter.exceptionCaught(ChannelHandlerContext ctx,
Throwable cause)
|
void |
ChannelOutboundHandlerAdapter.flush(ChannelHandlerContext ctx)
|
void |
CombinedChannelDuplexHandler.flush(ChannelHandlerContext ctx) |
void |
ChannelDuplexHandler.flush(ChannelHandlerContext ctx)
|
void |
ChannelOutboundHandler.flush(ChannelHandlerContext ctx)
Called once a flush operation is made.
|
void |
ChannelHandler.handlerAdded(ChannelHandlerContext ctx)
Gets called after the
ChannelHandler was added to the actual context and it's ready to handle events. |
void |
CombinedChannelDuplexHandler.handlerAdded(ChannelHandlerContext ctx) |
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 |
CombinedChannelDuplexHandler.handlerRemoved(ChannelHandlerContext ctx) |
void |
ChannelHandlerAdapter.handlerRemoved(ChannelHandlerContext ctx)
Do nothing by default, sub-classes may override this method.
|
void |
ChannelOutboundHandlerAdapter.read(ChannelHandlerContext ctx)
|
void |
CombinedChannelDuplexHandler.read(ChannelHandlerContext ctx) |
void |
ChannelDuplexHandler.read(ChannelHandlerContext ctx)
|
void |
ChannelOutboundHandler.read(ChannelHandlerContext ctx)
Intercepts
read() . |
void |
ChannelInboundHandler.userEventTriggered(ChannelHandlerContext ctx,
Object evt)
Gets called if an user event was triggered.
|
void |
CombinedChannelDuplexHandler.userEventTriggered(ChannelHandlerContext ctx,
Object evt) |
void |
ChannelInboundHandlerAdapter.userEventTriggered(ChannelHandlerContext ctx,
Object evt)
Calls
fireUserEventTriggered(Object) to forward
to the next ChannelInboundHandler in the ChannelPipeline . |
void |
ChannelOutboundHandlerAdapter.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise)
|
void |
CombinedChannelDuplexHandler.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise) |
void |
ChannelDuplexHandler.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise)
Calls
write(Object, ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
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 ByteBuf |
LengthFieldPrepender.allocateBuffer(ChannelHandlerContext ctx,
ByteBuf msg,
boolean preferDirect) |
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 |
MessageToMessageDecoder.channelRead(ChannelHandlerContext ctx,
Object msg) |
void |
ByteToMessageCodec.channelRead(ChannelHandlerContext ctx,
Object msg) |
void |
ByteToMessageDecoder.channelRead(ChannelHandlerContext ctx,
Object msg) |
void |
MessageToMessageCodec.channelRead(ChannelHandlerContext ctx,
Object msg) |
void |
ByteToMessageDecoder.channelReadComplete(ChannelHandlerContext ctx) |
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 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 abstract void |
ByteToMessageCodec.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 void |
LineBasedFrameDecoder.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 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 |
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,
ByteBuf 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.
|
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 |
MessageToMessageEncoder.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise) |
void |
ByteToMessageCodec.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise) |
void |
MessageToMessageCodec.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 |
JdkZlibEncoder.allocateBuffer(ChannelHandlerContext ctx,
ByteBuf msg,
boolean preferDirect) |
void |
JZlibEncoder.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
JdkZlibEncoder.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
protected void |
SnappyFramedDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
JdkZlibDecoder.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 |
SnappyFramedEncoder.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 |
HttpContentEncoder.channelInactive(ChannelHandlerContext ctx) |
void |
HttpObjectAggregator.channelInactive(ChannelHandlerContext ctx) |
void |
HttpContentDecoder.channelInactive(ChannelHandlerContext ctx) |
protected void |
HttpObjectDecoder.decode(ChannelHandlerContext ctx,
ByteBuf buffer,
List<Object> out) |
protected void |
HttpObjectAggregator.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) |
void |
HttpObjectAggregator.handlerAdded(ChannelHandlerContext ctx) |
void |
HttpContentEncoder.handlerRemoved(ChannelHandlerContext ctx) |
void |
HttpObjectAggregator.handlerRemoved(ChannelHandlerContext ctx) |
void |
HttpContentDecoder.handlerRemoved(ChannelHandlerContext ctx) |
HttpContent |
HttpChunkedInput.readChunk(ChannelHandlerContext ctx) |
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 |
WebSocket08FrameDecoder.channelInactive(ChannelHandlerContext ctx) |
void |
WebSocketFrameAggregator.channelInactive(ChannelHandlerContext ctx) |
protected void |
WebSocket08FrameDecoder.checkCloseFrameBody(ChannelHandlerContext ctx,
ByteBuf buffer) |
protected void |
WebSocket08FrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
WebSocket00FrameDecoder.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 |
WebSocketFrameAggregator.decode(ChannelHandlerContext ctx,
WebSocketFrame msg,
List<Object> out) |
protected void |
WebSocket08FrameEncoder.encode(ChannelHandlerContext ctx,
WebSocketFrame msg,
List<Object> out) |
protected void |
WebSocket00FrameEncoder.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) |
void |
WebSocketFrameAggregator.handlerRemoved(ChannelHandlerContext ctx) |
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 |
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 |
SocksAuthRequestDecoder.decode(ChannelHandlerContext ctx,
ByteBuf byteBuf,
List<Object> out) |
protected void |
SocksCmdRequestDecoder.decode(ChannelHandlerContext ctx,
ByteBuf byteBuf,
List<Object> out) |
protected void |
SocksCmdResponseDecoder.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 |
SocksInitResponseDecoder.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 |
SpdyFrameCodec.bind(ChannelHandlerContext ctx,
SocketAddress localAddress,
ChannelPromise promise) |
void |
SpdySessionHandler.channelInactive(ChannelHandlerContext ctx) |
void |
SpdySessionHandler.channelRead(ChannelHandlerContext ctx,
Object msg) |
void |
SpdyFrameCodec.channelReadComplete(ChannelHandlerContext ctx) |
void |
SpdyFrameCodec.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
SpdySessionHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
SpdyFrameCodec.connect(ChannelHandlerContext ctx,
SocketAddress remoteAddress,
SocketAddress localAddress,
ChannelPromise promise) |
protected void |
SpdyOrHttpChooser.decode(ChannelHandlerContext ctx,
ByteBuf in,
List<Object> out) |
protected void |
SpdyFrameCodec.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) |
void |
SpdyFrameCodec.deregister(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
SpdyFrameCodec.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise) |
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.flush(ChannelHandlerContext ctx) |
void |
SpdyFrameCodec.handlerAdded(ChannelHandlerContext ctx) |
void |
SpdyFrameCodec.read(ChannelHandlerContext ctx) |
void |
SpdyFrameCodec.write(ChannelHandlerContext ctx,
Object msg,
ChannelPromise promise) |
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 |
---|---|
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 |
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 |
ChannelTrafficShapingHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
GlobalTrafficShapingHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
GlobalChannelTrafficShapingHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
ChannelTrafficShapingHandler.handlerRemoved(ChannelHandlerContext ctx) |
void |
GlobalTrafficShapingHandler.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-2016 The Netty Project. All Rights Reserved.