Package | Description |
---|---|
org.jboss.netty.channel |
The core channel API which is asynchronous and event-driven abstraction of
various transports such as a
NIO Channel.
|
org.jboss.netty.example.discard | |
org.jboss.netty.example.echo | |
org.jboss.netty.example.factorial | |
org.jboss.netty.example.http.file | |
org.jboss.netty.example.http.helloworld | |
org.jboss.netty.example.http.snoop | |
org.jboss.netty.example.http.upload | |
org.jboss.netty.example.http.websocketx.autobahn |
This package is intended for use with testing against the Python
AutoBahn test suite.
|
org.jboss.netty.example.http.websocketx.client |
This is an example web service client.
|
org.jboss.netty.example.http.websocketx.server |
This package contains an example web socket web server.
|
org.jboss.netty.example.localtime | |
org.jboss.netty.example.objectecho | |
org.jboss.netty.example.portunification | |
org.jboss.netty.example.proxy | |
org.jboss.netty.example.qotm | |
org.jboss.netty.example.securechat | |
org.jboss.netty.example.telnet | |
org.jboss.netty.example.uptime | |
org.jboss.netty.handler.codec.base64 |
Encoder and decoder which transform a
Base64-encoded
String or ChannelBuffer
into a decoded ChannelBuffer and vice versa. |
org.jboss.netty.handler.codec.compression |
Encoder and decoder which compresses and decompresses
ChannelBuffer s
in a compression format such as zlib
and gzip. |
org.jboss.netty.handler.codec.frame |
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.
|
org.jboss.netty.handler.codec.http |
Encoder, decoder and their related message types for HTTP.
|
org.jboss.netty.handler.codec.http.websocketx |
Encoder, decoder, handshakers and their related message types for
Web Socket data frames.
|
org.jboss.netty.handler.codec.marshalling |
Decoder and Encoder which uses JBoss Marshalling.
|
org.jboss.netty.handler.codec.oneone |
Simplistic abstract classes which help implement encoder and decoder that
transform an object into another object and vice versa.
|
org.jboss.netty.handler.codec.protobuf |
Encoder and decoder which transform a
Google Protocol Buffers
Message into a ChannelBuffer
and vice versa. |
org.jboss.netty.handler.codec.replay |
Specialized variation of
FrameDecoder
which enables implementation of a non-blocking decoder in the blocking I/O
paradigm. |
org.jboss.netty.handler.codec.rtsp |
An RTSP
extension based on the HTTP codec.
|
org.jboss.netty.handler.codec.serialization |
Encoder, decoder and their compatibility stream implementations which
transform a
Serializable object into a byte buffer and
vice versa. |
org.jboss.netty.handler.codec.socks |
Encoder, decoder and their related message types for Socks.
|
org.jboss.netty.handler.codec.spdy |
Encoder, decoder, session handler and their related message types for the SPDY protocol.
|
org.jboss.netty.handler.codec.string |
Encoder and decoder which transform a
String into a
ChannelBuffer and vice versa. |
org.jboss.netty.handler.execution |
Executor -based implementation of various
thread models that separate business logic from I/O threads |
org.jboss.netty.handler.ipfilter |
Implementation of a Ip based Filter handlers.
|
org.jboss.netty.handler.logging |
Logs a
ChannelEvent for debugging purpose
using an InternalLogger . |
org.jboss.netty.handler.queue |
The special-purpose handlers that store an event into an internal queue
instead of propagating the event immediately.
|
org.jboss.netty.handler.ssl | |
org.jboss.netty.handler.stream |
Writes very large data stream asynchronously neither spending a lot of
memory nor getting
OutOfMemoryError . |
org.jboss.netty.handler.timeout |
Adds support for read and write timeout and idle connection notification
using a
Timer . |
org.jboss.netty.handler.traffic |
Implementation of a Traffic Shaping Handler and Dynamic Statistics.
|
Modifier and Type | Method and Description |
---|---|
ChannelHandlerContext |
ChannelPipeline.getContext(ChannelHandler handler)
Returns the context object of the specified
ChannelHandler in
this pipeline. |
ChannelHandlerContext |
DefaultChannelPipeline.getContext(ChannelHandler handler) |
ChannelHandlerContext |
ChannelPipeline.getContext(Class<? extends ChannelHandler> handlerType)
Returns the context object of the
ChannelHandler of the
specified type in this pipeline. |
ChannelHandlerContext |
DefaultChannelPipeline.getContext(Class<? extends ChannelHandler> handlerType) |
ChannelHandlerContext |
ChannelPipeline.getContext(String name)
Returns the context object of the
ChannelHandler with the
specified name in this pipeline. |
ChannelHandlerContext |
DefaultChannelPipeline.getContext(String name) |
Modifier and Type | Method and Description |
---|---|
void |
LifeCycleAwareChannelHandler.afterAdd(ChannelHandlerContext ctx) |
void |
LifeCycleAwareChannelHandler.afterRemove(ChannelHandlerContext ctx) |
void |
LifeCycleAwareChannelHandler.beforeAdd(ChannelHandlerContext ctx) |
void |
LifeCycleAwareChannelHandler.beforeRemove(ChannelHandlerContext ctx) |
static void |
Channels.bind(ChannelHandlerContext ctx,
ChannelFuture future,
SocketAddress localAddress)
Sends a
"bind" request to the
ChannelDownstreamHandler which is placed in the closest
downstream from the handler associated with the specified
ChannelHandlerContext . |
void |
SimpleChannelHandler.bindRequested(ChannelHandlerContext ctx,
ChannelStateEvent e)
Invoked when
Channel.bind(SocketAddress) was called. |
void |
SimpleChannelDownstreamHandler.bindRequested(ChannelHandlerContext ctx,
ChannelStateEvent e)
Invoked when
Channel.bind(SocketAddress) was called. |
void |
SimpleChannelHandler.channelBound(ChannelHandlerContext ctx,
ChannelStateEvent e)
Invoked when a
Channel is open and bound to a local address,
but not connected. |
void |
SimpleChannelUpstreamHandler.channelBound(ChannelHandlerContext ctx,
ChannelStateEvent e)
Invoked when a
Channel is open and bound to a local address,
but not connected. |
void |
SimpleChannelHandler.channelClosed(ChannelHandlerContext ctx,
ChannelStateEvent e)
Invoked when a
Channel was closed and all its related resources
were released. |
void |
SimpleChannelUpstreamHandler.channelClosed(ChannelHandlerContext ctx,
ChannelStateEvent e)
Invoked when a
Channel was closed and all its related resources
were released. |
void |
SimpleChannelHandler.channelConnected(ChannelHandlerContext ctx,
ChannelStateEvent e)
Invoked when a
Channel is open, bound to a local address, and
connected to a remote address. |
void |
SimpleChannelUpstreamHandler.channelConnected(ChannelHandlerContext ctx,
ChannelStateEvent e)
Invoked when a
Channel is open, bound to a local address, and
connected to a remote address. |
void |
SimpleChannelHandler.channelDisconnected(ChannelHandlerContext ctx,
ChannelStateEvent e)
Invoked when a
Channel was disconnected from its remote peer. |
void |
SimpleChannelUpstreamHandler.channelDisconnected(ChannelHandlerContext ctx,
ChannelStateEvent e)
Invoked when a
Channel was disconnected from its remote peer. |
void |
SimpleChannelHandler.channelInterestChanged(ChannelHandlerContext ctx,
ChannelStateEvent e)
Invoked when a
Channel 's interestOps
was changed. |
void |
SimpleChannelUpstreamHandler.channelInterestChanged(ChannelHandlerContext ctx,
ChannelStateEvent e)
Invoked when a
Channel 's interestOps
was changed. |
void |
SimpleChannelHandler.channelOpen(ChannelHandlerContext ctx,
ChannelStateEvent e)
Invoked when a
Channel is open, but not bound nor connected. |
void |
SimpleChannelUpstreamHandler.channelOpen(ChannelHandlerContext ctx,
ChannelStateEvent e)
Invoked when a
Channel is open, but not bound nor connected. |
void |
SimpleChannelHandler.channelUnbound(ChannelHandlerContext ctx,
ChannelStateEvent e)
Invoked when a
Channel was unbound from the current local address. |
void |
SimpleChannelUpstreamHandler.channelUnbound(ChannelHandlerContext ctx,
ChannelStateEvent e)
Invoked when a
Channel was unbound from the current local address. |
void |
SimpleChannelHandler.childChannelClosed(ChannelHandlerContext ctx,
ChildChannelStateEvent e)
Invoked when a child
Channel was closed. |
void |
SimpleChannelUpstreamHandler.childChannelClosed(ChannelHandlerContext ctx,
ChildChannelStateEvent e)
Invoked when a child
Channel was closed. |
void |
SimpleChannelHandler.childChannelOpen(ChannelHandlerContext ctx,
ChildChannelStateEvent e)
Invoked when a child
Channel was open. |
void |
SimpleChannelUpstreamHandler.childChannelOpen(ChannelHandlerContext ctx,
ChildChannelStateEvent e)
Invoked when a child
Channel was open. |
static void |
Channels.close(ChannelHandlerContext ctx,
ChannelFuture future)
Sends a
"close" request to the
ChannelDownstreamHandler which is placed in the closest
downstream from the handler associated with the specified
ChannelHandlerContext . |
void |
SimpleChannelHandler.closeRequested(ChannelHandlerContext ctx,
ChannelStateEvent e)
Invoked when
Channel.close() was called. |
void |
SimpleChannelDownstreamHandler.closeRequested(ChannelHandlerContext ctx,
ChannelStateEvent e)
Invoked when
Channel.close() was called. |
static void |
Channels.connect(ChannelHandlerContext ctx,
ChannelFuture future,
SocketAddress remoteAddress)
Sends a
"connect" request to the
ChannelDownstreamHandler which is placed in the closest
downstream from the handler associated with the specified
ChannelHandlerContext . |
void |
SimpleChannelHandler.connectRequested(ChannelHandlerContext ctx,
ChannelStateEvent e)
Invoked when
Channel.connect(SocketAddress) was called. |
void |
SimpleChannelDownstreamHandler.connectRequested(ChannelHandlerContext ctx,
ChannelStateEvent e)
Invoked when
Channel.connect(SocketAddress) was called. |
static void |
Channels.disconnect(ChannelHandlerContext ctx,
ChannelFuture future)
Sends a
"disconnect" request to the
ChannelDownstreamHandler which is placed in the closest
downstream from the handler associated with the specified
ChannelHandlerContext . |
void |
SimpleChannelHandler.disconnectRequested(ChannelHandlerContext ctx,
ChannelStateEvent e)
Invoked when
Channel.disconnect() was called. |
void |
SimpleChannelDownstreamHandler.disconnectRequested(ChannelHandlerContext ctx,
ChannelStateEvent e)
Invoked when
Channel.disconnect() was called. |
void |
SimpleChannelHandler.exceptionCaught(ChannelHandlerContext ctx,
ExceptionEvent e)
Invoked when an exception was raised by an I/O thread or a
ChannelHandler . |
void |
SimpleChannelUpstreamHandler.exceptionCaught(ChannelHandlerContext ctx,
ExceptionEvent e)
Invoked when an exception was raised by an I/O thread or a
ChannelHandler . |
static void |
Channels.fireChannelBound(ChannelHandlerContext ctx,
SocketAddress localAddress)
Sends a
"channelBound" event to the
ChannelUpstreamHandler which is placed in the closest upstream
from the handler associated with the specified
ChannelHandlerContext . |
static void |
Channels.fireChannelClosed(ChannelHandlerContext ctx)
Sends a
"channelClosed" event to the
ChannelUpstreamHandler which is placed in the closest upstream
from the handler associated with the specified
ChannelHandlerContext . |
static void |
Channels.fireChannelConnected(ChannelHandlerContext ctx,
SocketAddress remoteAddress)
Sends a
"channelConnected" event to the
ChannelUpstreamHandler which is placed in the closest upstream
from the handler associated with the specified
ChannelHandlerContext . |
static void |
Channels.fireChannelDisconnected(ChannelHandlerContext ctx)
Sends a
"channelDisconnected" event to the
ChannelUpstreamHandler which is placed in the closest upstream
from the handler associated with the specified
ChannelHandlerContext . |
static void |
Channels.fireChannelInterestChanged(ChannelHandlerContext ctx)
Sends a
"channelInterestChanged" event to the
ChannelUpstreamHandler which is placed in the closest upstream
from the handler associated with the specified
ChannelHandlerContext . |
static void |
Channels.fireChannelOpen(ChannelHandlerContext ctx)
Sends a
"channelOpen" event to the
ChannelUpstreamHandler which is placed in the closest upstream
from the handler associated with the specified
ChannelHandlerContext . |
static void |
Channels.fireChannelUnbound(ChannelHandlerContext ctx)
Sends a
"channelUnbound" event to the
ChannelUpstreamHandler which is placed in the closest upstream
from the handler associated with the specified
ChannelHandlerContext . |
static void |
Channels.fireExceptionCaught(ChannelHandlerContext ctx,
Throwable cause)
Sends a
"exceptionCaught" event to the
ChannelUpstreamHandler which is placed in the closest upstream
from the handler associated with the specified
ChannelHandlerContext . |
static ChannelFuture |
Channels.fireExceptionCaughtLater(ChannelHandlerContext ctx,
Throwable cause)
Sends a
"exceptionCaught" event to the
ChannelUpstreamHandler which is placed in the closest upstream
from the handler associated with the specified
ChannelHandlerContext once the io-thread runs again. |
static void |
Channels.fireMessageReceived(ChannelHandlerContext ctx,
Object message)
Sends a
"messageReceived" event to the
ChannelUpstreamHandler which is placed in the closest upstream
from the handler associated with the specified
ChannelHandlerContext . |
static void |
Channels.fireMessageReceived(ChannelHandlerContext ctx,
Object message,
SocketAddress remoteAddress)
Sends a
"messageReceived" event to the
ChannelUpstreamHandler which is placed in the closest upstream
from the handler associated with the specified
ChannelHandlerContext . |
static void |
Channels.fireWriteComplete(ChannelHandlerContext ctx,
long amount)
Sends a
"writeComplete" event to the
ChannelUpstreamHandler which is placed in the closest upstream
from the handler associated with the specified
ChannelHandlerContext . |
void |
SimpleChannelHandler.handleDownstream(ChannelHandlerContext ctx,
ChannelEvent e)
Handles the specified downstream event.
|
void |
ChannelDownstreamHandler.handleDownstream(ChannelHandlerContext ctx,
ChannelEvent e)
Handles the specified downstream event.
|
void |
SimpleChannelDownstreamHandler.handleDownstream(ChannelHandlerContext ctx,
ChannelEvent e)
Handles the specified downstream event.
|
void |
ChannelUpstreamHandler.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e)
Handles the specified upstream event.
|
void |
SimpleChannelHandler.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e)
Handles the specified upstream event.
|
void |
SimpleChannelUpstreamHandler.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e)
Handles the specified upstream event.
|
void |
SimpleChannelHandler.messageReceived(ChannelHandlerContext ctx,
MessageEvent e)
Invoked when a message object (e.g:
ChannelBuffer ) was received
from a remote peer. |
void |
SimpleChannelUpstreamHandler.messageReceived(ChannelHandlerContext ctx,
MessageEvent e)
Invoked when a message object (e.g:
ChannelBuffer ) was received
from a remote peer. |
static void |
Channels.setInterestOps(ChannelHandlerContext ctx,
ChannelFuture future,
int interestOps)
Sends a
"setInterestOps" request to the
ChannelDownstreamHandler which is placed in the closest
downstream from the handler associated with the specified
ChannelHandlerContext . |
void |
SimpleChannelHandler.setInterestOpsRequested(ChannelHandlerContext ctx,
ChannelStateEvent e)
Invoked when
Channel.setInterestOps(int) was called. |
void |
SimpleChannelDownstreamHandler.setInterestOpsRequested(ChannelHandlerContext ctx,
ChannelStateEvent e)
Invoked when
Channel.setInterestOps(int) was called. |
static void |
Channels.unbind(ChannelHandlerContext ctx,
ChannelFuture future)
Sends a
"unbind" request to the
ChannelDownstreamHandler which is placed in the closest
downstream from the handler associated with the specified
ChannelHandlerContext . |
void |
SimpleChannelHandler.unbindRequested(ChannelHandlerContext ctx,
ChannelStateEvent e)
Invoked when
Channel.unbind() was called. |
void |
SimpleChannelDownstreamHandler.unbindRequested(ChannelHandlerContext ctx,
ChannelStateEvent e)
Invoked when
Channel.unbind() was called. |
static void |
Channels.write(ChannelHandlerContext ctx,
ChannelFuture future,
Object message)
Sends a
"write" request to the
ChannelDownstreamHandler which is placed in the closest
downstream from the handler associated with the specified
ChannelHandlerContext . |
static void |
Channels.write(ChannelHandlerContext ctx,
ChannelFuture future,
Object message,
SocketAddress remoteAddress)
Sends a
"write" request to the
ChannelDownstreamHandler which is placed in the closest
downstream from the handler associated with the specified
ChannelHandlerContext . |
void |
SimpleChannelHandler.writeComplete(ChannelHandlerContext ctx,
WriteCompletionEvent e)
Invoked when something was written into a
Channel . |
void |
SimpleChannelUpstreamHandler.writeComplete(ChannelHandlerContext ctx,
WriteCompletionEvent e)
Invoked when something was written into a
Channel . |
void |
SimpleChannelHandler.writeRequested(ChannelHandlerContext ctx,
MessageEvent e)
Invoked when
Channel.write(Object) is called. |
void |
SimpleChannelDownstreamHandler.writeRequested(ChannelHandlerContext ctx,
MessageEvent e)
Invoked when
Channel.write(Object) is called. |
Modifier and Type | Method and Description |
---|---|
void |
DiscardClientHandler.channelConnected(ChannelHandlerContext ctx,
ChannelStateEvent e) |
void |
DiscardClientHandler.channelInterestChanged(ChannelHandlerContext ctx,
ChannelStateEvent e) |
void |
DiscardClientHandler.exceptionCaught(ChannelHandlerContext ctx,
ExceptionEvent e) |
void |
DiscardServerHandler.exceptionCaught(ChannelHandlerContext ctx,
ExceptionEvent e) |
void |
DiscardClientHandler.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e) |
void |
DiscardServerHandler.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e) |
void |
DiscardClientHandler.messageReceived(ChannelHandlerContext ctx,
MessageEvent e) |
void |
DiscardServerHandler.messageReceived(ChannelHandlerContext ctx,
MessageEvent e) |
void |
DiscardClientHandler.writeComplete(ChannelHandlerContext ctx,
WriteCompletionEvent e) |
Modifier and Type | Method and Description |
---|---|
void |
EchoClientHandler.channelConnected(ChannelHandlerContext ctx,
ChannelStateEvent e) |
void |
EchoClientHandler.exceptionCaught(ChannelHandlerContext ctx,
ExceptionEvent e) |
void |
EchoServerHandler.exceptionCaught(ChannelHandlerContext ctx,
ExceptionEvent e) |
void |
EchoClientHandler.messageReceived(ChannelHandlerContext ctx,
MessageEvent e) |
void |
EchoServerHandler.messageReceived(ChannelHandlerContext ctx,
MessageEvent e) |
Modifier and Type | Method and Description |
---|---|
void |
HttpStaticFileServerHandler.exceptionCaught(ChannelHandlerContext ctx,
ExceptionEvent e) |
void |
HttpStaticFileServerHandler.messageReceived(ChannelHandlerContext ctx,
MessageEvent e) |
Modifier and Type | Method and Description |
---|---|
void |
HttpHelloWorldServerHandler.exceptionCaught(ChannelHandlerContext ctx,
ExceptionEvent e) |
void |
HttpHelloWorldServerHandler.messageReceived(ChannelHandlerContext ctx,
MessageEvent e) |
Modifier and Type | Method and Description |
---|---|
void |
HttpSnoopServerHandler.exceptionCaught(ChannelHandlerContext ctx,
ExceptionEvent e) |
void |
HttpSnoopServerHandler.messageReceived(ChannelHandlerContext ctx,
MessageEvent e) |
void |
HttpSnoopClientHandler.messageReceived(ChannelHandlerContext ctx,
MessageEvent e) |
Modifier and Type | Method and Description |
---|---|
void |
HttpUploadServerHandler.channelClosed(ChannelHandlerContext ctx,
ChannelStateEvent e) |
void |
HttpUploadServerHandler.exceptionCaught(ChannelHandlerContext ctx,
ExceptionEvent e) |
void |
HttpUploadClientHandler.exceptionCaught(ChannelHandlerContext ctx,
ExceptionEvent e) |
void |
HttpUploadServerHandler.messageReceived(ChannelHandlerContext ctx,
MessageEvent e) |
void |
HttpUploadClientHandler.messageReceived(ChannelHandlerContext ctx,
MessageEvent e) |
Modifier and Type | Method and Description |
---|---|
void |
AutobahnServerHandler.exceptionCaught(ChannelHandlerContext ctx,
ExceptionEvent e) |
void |
AutobahnServerHandler.messageReceived(ChannelHandlerContext ctx,
MessageEvent e) |
Modifier and Type | Method and Description |
---|---|
void |
WebSocketClientHandler.channelClosed(ChannelHandlerContext ctx,
ChannelStateEvent e) |
void |
WebSocketClientHandler.exceptionCaught(ChannelHandlerContext ctx,
ExceptionEvent e) |
void |
WebSocketClientHandler.messageReceived(ChannelHandlerContext ctx,
MessageEvent e) |
Modifier and Type | Method and Description |
---|---|
void |
WebSocketServerHandler.exceptionCaught(ChannelHandlerContext ctx,
ExceptionEvent e) |
void |
WebSocketServerHandler.messageReceived(ChannelHandlerContext ctx,
MessageEvent e) |
Modifier and Type | Method and Description |
---|---|
void |
LocalTimeClientHandler.channelOpen(ChannelHandlerContext ctx,
ChannelStateEvent e) |
void |
LocalTimeClientHandler.exceptionCaught(ChannelHandlerContext ctx,
ExceptionEvent e) |
void |
LocalTimeServerHandler.exceptionCaught(ChannelHandlerContext ctx,
ExceptionEvent e) |
void |
LocalTimeClientHandler.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e) |
void |
LocalTimeServerHandler.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e) |
void |
LocalTimeClientHandler.messageReceived(ChannelHandlerContext ctx,
MessageEvent e) |
void |
LocalTimeServerHandler.messageReceived(ChannelHandlerContext ctx,
MessageEvent e) |
Modifier and Type | Method and Description |
---|---|
void |
ObjectEchoClientHandler.channelConnected(ChannelHandlerContext ctx,
ChannelStateEvent e) |
void |
ObjectEchoClientHandler.exceptionCaught(ChannelHandlerContext ctx,
ExceptionEvent e) |
void |
ObjectEchoServerHandler.exceptionCaught(ChannelHandlerContext ctx,
ExceptionEvent e) |
void |
ObjectEchoClientHandler.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e) |
void |
ObjectEchoServerHandler.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e) |
void |
ObjectEchoClientHandler.messageReceived(ChannelHandlerContext ctx,
MessageEvent e) |
void |
ObjectEchoServerHandler.messageReceived(ChannelHandlerContext ctx,
MessageEvent e) |
Modifier and Type | Method and Description |
---|---|
protected Object |
PortUnificationServerHandler.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer) |
Modifier and Type | Method and Description |
---|---|
void |
HexDumpProxyInboundHandler.channelClosed(ChannelHandlerContext ctx,
ChannelStateEvent e) |
void |
HexDumpProxyInboundHandler.channelInterestChanged(ChannelHandlerContext ctx,
ChannelStateEvent e) |
void |
HexDumpProxyInboundHandler.channelOpen(ChannelHandlerContext ctx,
ChannelStateEvent e) |
void |
HexDumpProxyInboundHandler.exceptionCaught(ChannelHandlerContext ctx,
ExceptionEvent e) |
void |
HexDumpProxyInboundHandler.messageReceived(ChannelHandlerContext ctx,
MessageEvent e) |
Modifier and Type | Method and Description |
---|---|
void |
QuoteOfTheMomentClientHandler.exceptionCaught(ChannelHandlerContext ctx,
ExceptionEvent e) |
void |
QuoteOfTheMomentServerHandler.exceptionCaught(ChannelHandlerContext ctx,
ExceptionEvent e) |
void |
QuoteOfTheMomentClientHandler.messageReceived(ChannelHandlerContext ctx,
MessageEvent e) |
void |
QuoteOfTheMomentServerHandler.messageReceived(ChannelHandlerContext ctx,
MessageEvent e) |
Modifier and Type | Method and Description |
---|---|
void |
SecureChatServerHandler.channelConnected(ChannelHandlerContext ctx,
ChannelStateEvent e) |
void |
SecureChatServerHandler.channelDisconnected(ChannelHandlerContext ctx,
ChannelStateEvent e) |
void |
SecureChatServerHandler.exceptionCaught(ChannelHandlerContext ctx,
ExceptionEvent e) |
void |
SecureChatClientHandler.exceptionCaught(ChannelHandlerContext ctx,
ExceptionEvent e) |
void |
SecureChatServerHandler.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e) |
void |
SecureChatClientHandler.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e) |
void |
SecureChatServerHandler.messageReceived(ChannelHandlerContext ctx,
MessageEvent e) |
void |
SecureChatClientHandler.messageReceived(ChannelHandlerContext ctx,
MessageEvent e) |
Modifier and Type | Method and Description |
---|---|
void |
TelnetServerHandler.channelConnected(ChannelHandlerContext ctx,
ChannelStateEvent e) |
void |
TelnetServerHandler.exceptionCaught(ChannelHandlerContext ctx,
ExceptionEvent e) |
void |
TelnetClientHandler.exceptionCaught(ChannelHandlerContext ctx,
ExceptionEvent e) |
void |
TelnetServerHandler.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e) |
void |
TelnetClientHandler.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e) |
void |
TelnetServerHandler.messageReceived(ChannelHandlerContext ctx,
MessageEvent e) |
void |
TelnetClientHandler.messageReceived(ChannelHandlerContext ctx,
MessageEvent e) |
Modifier and Type | Method and Description |
---|---|
void |
UptimeClientHandler.channelClosed(ChannelHandlerContext ctx,
ChannelStateEvent e) |
void |
UptimeClientHandler.channelConnected(ChannelHandlerContext ctx,
ChannelStateEvent e) |
void |
UptimeClientHandler.channelDisconnected(ChannelHandlerContext ctx,
ChannelStateEvent e) |
void |
UptimeClientHandler.exceptionCaught(ChannelHandlerContext ctx,
ExceptionEvent e) |
Modifier and Type | Method and Description |
---|---|
protected Object |
Base64Decoder.decode(ChannelHandlerContext ctx,
Channel channel,
Object msg) |
protected Object |
Base64Encoder.encode(ChannelHandlerContext ctx,
Channel channel,
Object msg) |
Modifier and Type | Method and Description |
---|---|
void |
FrameDecoder.afterAdd(ChannelHandlerContext ctx) |
void |
FrameDecoder.afterRemove(ChannelHandlerContext ctx) |
void |
FrameDecoder.beforeAdd(ChannelHandlerContext ctx) |
void |
FrameDecoder.beforeRemove(ChannelHandlerContext ctx) |
void |
FrameDecoder.channelClosed(ChannelHandlerContext ctx,
ChannelStateEvent e) |
void |
FrameDecoder.channelDisconnected(ChannelHandlerContext ctx,
ChannelStateEvent e) |
protected void |
FrameDecoder.cleanup(ChannelHandlerContext ctx,
ChannelStateEvent e)
|
protected abstract Object |
FrameDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer)
Decodes the received packets so far into a frame.
|
protected Object |
LineBasedFrameDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer) |
protected Object |
LengthFieldBasedFrameDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer) |
protected Object |
FixedLengthFrameDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer) |
protected Object |
DelimiterBasedFrameDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer) |
protected Object |
FrameDecoder.decodeLast(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer)
Decodes the received data so far into a frame when the channel is
disconnected.
|
protected Object |
LengthFieldPrepender.encode(ChannelHandlerContext ctx,
Channel channel,
Object msg) |
void |
FrameDecoder.exceptionCaught(ChannelHandlerContext ctx,
ExceptionEvent e) |
void |
FrameDecoder.messageReceived(ChannelHandlerContext ctx,
MessageEvent e) |
protected ChannelBuffer |
FrameDecoder.newCumulationBuffer(ChannelHandlerContext ctx,
int minimumCapacity)
Create a new
ChannelBuffer which is used for the cumulation. |
protected ChannelBuffer |
FixedLengthFrameDecoder.newCumulationBuffer(ChannelHandlerContext ctx,
int minimumCapacity) |
protected void |
FrameDecoder.unfoldAndFireMessageReceived(ChannelHandlerContext context,
SocketAddress remoteAddress,
Object result) |
protected ChannelBuffer |
FrameDecoder.updateCumulation(ChannelHandlerContext ctx,
ChannelBuffer input) |
Modifier and Type | Method and Description |
---|---|
void |
WebSocketServerProtocolHandler.afterAdd(ChannelHandlerContext ctx) |
void |
WebSocketServerProtocolHandler.afterRemove(ChannelHandlerContext ctx) |
void |
WebSocketServerProtocolHandler.beforeAdd(ChannelHandlerContext ctx) |
void |
WebSocketServerProtocolHandler.beforeRemove(ChannelHandlerContext ctx) |
protected Object |
WebSocket00FrameDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer,
VoidEnum state) |
protected Object |
WebSocket08FrameDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer,
WebSocket08FrameDecoder.State state) |
protected Object |
WebSocketFrameAggregator.decode(ChannelHandlerContext ctx,
Channel channel,
Object message) |
protected Object |
WebSocket00FrameEncoder.encode(ChannelHandlerContext ctx,
Channel channel,
Object msg) |
protected Object |
WebSocket08FrameEncoder.encode(ChannelHandlerContext ctx,
Channel channel,
Object msg) |
void |
WebSocketServerProtocolHandler.exceptionCaught(ChannelHandlerContext ctx,
ExceptionEvent e) |
void |
WebSocketServerProtocolHandshakeHandler.exceptionCaught(ChannelHandlerContext ctx,
Throwable cause) |
void |
WebSocketServerProtocolHandshakeHandler.messageReceived(ChannelHandlerContext ctx,
MessageEvent e) |
void |
WebSocketServerProtocolHandler.messageReceived(ChannelHandlerContext ctx,
MessageEvent e) |
Modifier and Type | Method and Description |
---|---|
protected Object |
MarshallingDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer) |
protected Object |
CompatibleMarshallingDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer,
VoidEnum state) |
protected Object |
CompatibleMarshallingDecoder.decodeLast(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer,
VoidEnum state) |
protected Object |
CompatibleMarshallingEncoder.encode(ChannelHandlerContext ctx,
Channel channel,
Object msg) |
protected Object |
MarshallingEncoder.encode(ChannelHandlerContext ctx,
Channel channel,
Object msg) |
void |
CompatibleMarshallingDecoder.exceptionCaught(ChannelHandlerContext ctx,
ExceptionEvent e)
Calls
Channel.close() if a TooLongFrameException was thrown |
org.jboss.marshalling.Marshaller |
ThreadLocalMarshallerProvider.getMarshaller(ChannelHandlerContext ctx) |
org.jboss.marshalling.Marshaller |
MarshallerProvider.getMarshaller(ChannelHandlerContext ctx)
Get a
Marshaller for the given ChannelHandlerContext |
org.jboss.marshalling.Marshaller |
DefaultMarshallerProvider.getMarshaller(ChannelHandlerContext ctx) |
org.jboss.marshalling.Unmarshaller |
DefaultUnmarshallerProvider.getUnmarshaller(ChannelHandlerContext ctx) |
org.jboss.marshalling.Unmarshaller |
ContextBoundUnmarshallerProvider.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) |
Modifier and Type | Method and Description |
---|---|
protected abstract Object |
OneToOneDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
Object msg)
Transforms the specified received message into another message and return
the transformed message.
|
protected boolean |
OneToOneStrictEncoder.doEncode(ChannelHandlerContext ctx,
MessageEvent e) |
protected boolean |
OneToOneEncoder.doEncode(ChannelHandlerContext ctx,
MessageEvent e) |
protected abstract Object |
OneToOneEncoder.encode(ChannelHandlerContext ctx,
Channel channel,
Object msg)
Transforms the specified message into another message and return the
transformed message.
|
void |
OneToOneEncoder.handleDownstream(ChannelHandlerContext ctx,
ChannelEvent evt) |
void |
OneToOneDecoder.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent evt) |
Modifier and Type | Method and Description |
---|---|
protected Object |
ProtobufVarint32FrameDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer) |
protected Object |
ProtobufDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
Object msg) |
protected Object |
ProtobufVarint32LengthFieldPrepender.encode(ChannelHandlerContext ctx,
Channel channel,
Object msg) |
protected Object |
ProtobufEncoder.encode(ChannelHandlerContext ctx,
Channel channel,
Object msg) |
Modifier and Type | Method and Description |
---|---|
protected void |
ReplayingDecoder.cleanup(ChannelHandlerContext ctx,
ChannelStateEvent e) |
protected Object |
ReplayingDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer)
|
protected abstract Object |
ReplayingDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer,
T state)
Decodes the received packets so far into a frame.
|
protected Object |
ReplayingDecoder.decodeLast(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer) |
protected Object |
ReplayingDecoder.decodeLast(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer,
T state)
Decodes the received data so far into a frame when the channel is
disconnected.
|
void |
ReplayingDecoder.messageReceived(ChannelHandlerContext ctx,
MessageEvent e) |
Modifier and Type | Method and Description |
---|---|
protected Object |
RtspMessageDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer,
HttpMessageDecoder.State state) |
protected Object |
RtspMessageEncoder.encode(ChannelHandlerContext ctx,
Channel channel,
Object msg) |
Modifier and Type | Method and Description |
---|---|
protected Object |
ObjectDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer) |
protected Object |
ObjectEncoder.encode(ChannelHandlerContext ctx,
Channel channel,
Object msg) |
protected Object |
CompatibleObjectEncoder.encode(ChannelHandlerContext context,
Channel channel,
Object msg) |
Modifier and Type | Method and Description |
---|---|
protected Object |
SocksAuthRequestDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer,
org.jboss.netty.handler.codec.socks.SocksAuthRequestDecoder.State state) |
protected Object |
SocksAuthResponseDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer,
SocksAuthResponseDecoder.State state) |
protected Object |
SocksCmdRequestDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer,
org.jboss.netty.handler.codec.socks.SocksCmdRequestDecoder.State state) |
protected Object |
SocksCmdResponseDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer,
SocksCmdResponseDecoder.State state) |
protected Object |
SocksInitRequestDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer,
org.jboss.netty.handler.codec.socks.SocksInitRequestDecoder.State state) |
protected Object |
SocksInitResponseDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer,
SocksInitResponseDecoder.State state) |
protected Object |
SocksMessageEncoder.encode(ChannelHandlerContext ctx,
Channel channel,
Object msg) |
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.beforeAdd(ChannelHandlerContext ctx) |
protected void |
SpdyFrameCodec.cleanup(ChannelHandlerContext ctx,
ChannelStateEvent e) |
protected Object |
SpdyFrameCodec.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer) |
protected Object |
SpdyHttpDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
Object msg) |
void |
SpdySessionHandler.exceptionCaught(ChannelHandlerContext ctx,
ExceptionEvent e) |
void |
SpdyHttpCodec.handleDownstream(ChannelHandlerContext ctx,
ChannelEvent e) |
void |
SpdyHttpEncoder.handleDownstream(ChannelHandlerContext ctx,
ChannelEvent evt) |
void |
SpdyFrameCodec.handleDownstream(ChannelHandlerContext ctx,
ChannelEvent evt) |
void |
SpdySessionHandler.handleDownstream(ChannelHandlerContext ctx,
ChannelEvent evt) |
void |
SpdyHttpCodec.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e) |
void |
SpdyOrHttpChooser.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e) |
void |
SpdySessionHandler.messageReceived(ChannelHandlerContext ctx,
MessageEvent e) |
void |
SpdyHttpResponseStreamIdHandler.messageReceived(ChannelHandlerContext ctx,
MessageEvent e) |
protected void |
SpdyHttpEncoder.writeChunk(ChannelHandlerContext ctx,
ChannelFuture future,
int streamId,
HttpChunk chunk,
SocketAddress remoteAddress)
Writes an HTTP chunk downstream as one or more SPDY frames.
|
void |
SpdyHttpResponseStreamIdHandler.writeRequested(ChannelHandlerContext ctx,
MessageEvent e) |
Modifier and Type | Method and Description |
---|---|
protected Object |
StringDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
Object msg) |
protected Object |
StringEncoder.encode(ChannelHandlerContext ctx,
Channel channel,
Object msg) |
Modifier and Type | Field and Description |
---|---|
protected ChannelHandlerContext |
ChannelEventRunnable.ctx |
Modifier and Type | Method and Description |
---|---|
ChannelHandlerContext |
ChannelEventRunnable.getContext()
Returns the
ChannelHandlerContext which will be used to
send the ChannelEvent upstream. |
Modifier and Type | Method and Description |
---|---|
void |
ExecutionHandler.handleDownstream(ChannelHandlerContext ctx,
ChannelEvent e) |
protected boolean |
ExecutionHandler.handleReadSuspend(ChannelHandlerContext ctx,
ChannelEvent e)
Handle suspended reads
|
void |
ExecutionHandler.handleUpstream(ChannelHandlerContext context,
ChannelEvent e) |
Constructor and Description |
---|
ChannelDownstreamEventRunnable(ChannelHandlerContext ctx,
ChannelEvent e,
Executor executor) |
ChannelEventRunnable(ChannelHandlerContext ctx,
ChannelEvent e,
Executor executor)
Creates a
Runnable which sends the specified ChannelEvent
upstream via the specified ChannelHandlerContext . |
ChannelUpstreamEventRunnable(ChannelHandlerContext ctx,
ChannelEvent e,
Executor executor)
Creates a
Runnable which sends the specified ChannelEvent
upstream via the specified ChannelHandlerContext . |
Modifier and Type | Method and Description |
---|---|
protected boolean |
OneIpFilterHandler.accept(ChannelHandlerContext ctx,
ChannelEvent e,
InetSocketAddress inetSocketAddress) |
protected boolean |
IpFilterRuleHandler.accept(ChannelHandlerContext ctx,
ChannelEvent e,
InetSocketAddress inetSocketAddress) |
protected abstract boolean |
IpFilteringHandlerImpl.accept(ChannelHandlerContext ctx,
ChannelEvent e,
InetSocketAddress inetSocketAddress)
Called when the channel is connected.
|
ChannelFuture |
IpFilterListener.allowed(ChannelHandlerContext ctx,
ChannelEvent e,
InetSocketAddress inetSocketAddress)
Called when the channel has the CONNECTED status and the channel was allowed by a previous call to accept().
|
boolean |
IpFilterListener.continues(ChannelHandlerContext ctx,
ChannelEvent e)
Called in handleUpstream, if this channel was previously blocked,
to check if whatever the event, it should be passed to the next entry in the pipeline.
If one wants to not block events, just overridden this method by returning always true. Note that OPENED and BOUND events are still passed to the next entry in the pipeline since those events come out before the CONNECTED event and so the possibility to filter the connection. |
protected boolean |
IpFilteringHandlerImpl.continues(ChannelHandlerContext ctx,
ChannelEvent e)
Called in handleUpstream, if this channel was previously blocked,
to check if whatever the event, it should be passed to the next entry in the pipeline.
If one wants to not block events, just overridden this method by returning always true. Note that OPENED and BOUND events are still passed to the next entry in the pipeline since those events come out before the CONNECTED event and so the possibility to filter the connection. |
protected ChannelFuture |
IpFilteringHandlerImpl.handleAllowedChannel(ChannelHandlerContext ctx,
ChannelEvent e,
InetSocketAddress inetSocketAddress) |
protected ChannelFuture |
IpFilteringHandlerImpl.handleRefusedChannel(ChannelHandlerContext ctx,
ChannelEvent e,
InetSocketAddress inetSocketAddress)
Called when the channel has the CONNECTED status and the channel was refused by a previous call to accept().
|
void |
OneIpFilterHandler.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e) |
void |
IpFilteringHandlerImpl.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e) |
protected boolean |
IpFilteringHandlerImpl.isBlocked(ChannelHandlerContext ctx)
Internal method to test if the current channel is blocked.
|
ChannelFuture |
IpFilterListener.refused(ChannelHandlerContext ctx,
ChannelEvent e,
InetSocketAddress inetSocketAddress)
Called when the channel has the CONNECTED status and the channel was refused by a previous call to accept().
|
Modifier and Type | Method and Description |
---|---|
void |
LoggingHandler.handleDownstream(ChannelHandlerContext ctx,
ChannelEvent e) |
void |
LoggingHandler.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e) |
Modifier and Type | Method and Description |
---|---|
void |
BufferedWriteHandler.afterAdd(ChannelHandlerContext ctx) |
void |
BufferedWriteHandler.afterRemove(ChannelHandlerContext ctx)
Fail all buffered writes that are left.
|
void |
BufferedWriteHandler.beforeAdd(ChannelHandlerContext ctx) |
void |
BufferedWriteHandler.beforeRemove(ChannelHandlerContext ctx) |
void |
BlockingReadHandler.channelClosed(ChannelHandlerContext ctx,
ChannelStateEvent e) |
void |
BufferedWriteHandler.channelClosed(ChannelHandlerContext ctx,
ChannelStateEvent e)
Fail all buffered writes that are left.
|
void |
BufferedWriteHandler.closeRequested(ChannelHandlerContext ctx,
ChannelStateEvent e) |
void |
BufferedWriteHandler.disconnectRequested(ChannelHandlerContext ctx,
ChannelStateEvent e) |
void |
BlockingReadHandler.exceptionCaught(ChannelHandlerContext ctx,
ExceptionEvent e) |
void |
BlockingReadHandler.messageReceived(ChannelHandlerContext ctx,
MessageEvent e) |
void |
BufferedWriteHandler.writeRequested(ChannelHandlerContext ctx,
MessageEvent e)
Stores all write requests to the queue so that they are actually written
on
BufferedWriteHandler.flush() . |
Modifier and Type | Method and Description |
---|---|
void |
SslHandler.afterRemove(ChannelHandlerContext ctx)
Fail all pending writes which we were not able to flush out
|
void |
SslHandler.beforeAdd(ChannelHandlerContext ctx) |
void |
SslHandler.channelClosed(ChannelHandlerContext ctx,
ChannelStateEvent e)
Loop over all the pending writes and fail them.
|
void |
SslHandler.channelConnected(ChannelHandlerContext ctx,
ChannelStateEvent e)
Calls
SslHandler.handshake() once the Channel is connected |
void |
SslHandler.channelDisconnected(ChannelHandlerContext ctx,
ChannelStateEvent e) |
protected Object |
SslHandler.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer in) |
void |
SslHandler.exceptionCaught(ChannelHandlerContext ctx,
ExceptionEvent e) |
void |
SslHandler.handleDownstream(ChannelHandlerContext context,
ChannelEvent evt) |
Modifier and Type | Method and Description |
---|---|
void |
ChunkedWriteHandler.afterAdd(ChannelHandlerContext ctx) |
void |
ChunkedWriteHandler.afterRemove(ChannelHandlerContext ctx) |
void |
ChunkedWriteHandler.beforeAdd(ChannelHandlerContext ctx) |
void |
ChunkedWriteHandler.beforeRemove(ChannelHandlerContext ctx) |
void |
ChunkedWriteHandler.handleDownstream(ChannelHandlerContext ctx,
ChannelEvent e) |
void |
ChunkedWriteHandler.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e) |
Modifier and Type | Method and Description |
---|---|
void |
IdleStateHandler.afterAdd(ChannelHandlerContext ctx) |
void |
ReadTimeoutHandler.afterAdd(ChannelHandlerContext ctx) |
void |
IdleStateHandler.afterRemove(ChannelHandlerContext ctx) |
void |
ReadTimeoutHandler.afterRemove(ChannelHandlerContext ctx) |
void |
IdleStateHandler.beforeAdd(ChannelHandlerContext ctx) |
void |
ReadTimeoutHandler.beforeAdd(ChannelHandlerContext ctx) |
void |
IdleStateHandler.beforeRemove(ChannelHandlerContext ctx) |
void |
ReadTimeoutHandler.beforeRemove(ChannelHandlerContext ctx) |
void |
IdleStateHandler.channelClosed(ChannelHandlerContext ctx,
ChannelStateEvent e) |
void |
ReadTimeoutHandler.channelClosed(ChannelHandlerContext ctx,
ChannelStateEvent e) |
void |
IdleStateAwareChannelHandler.channelIdle(ChannelHandlerContext ctx,
IdleStateEvent e)
Invoked when a
Channel has been idle for a while. |
void |
IdleStateAwareChannelUpstreamHandler.channelIdle(ChannelHandlerContext ctx,
IdleStateEvent e)
Invoked when a
Channel has been idle for a while. |
protected void |
IdleStateHandler.channelIdle(ChannelHandlerContext ctx,
IdleState state,
long lastActivityTimeMillis) |
void |
IdleStateHandler.channelOpen(ChannelHandlerContext ctx,
ChannelStateEvent e) |
void |
ReadTimeoutHandler.channelOpen(ChannelHandlerContext ctx,
ChannelStateEvent e) |
void |
IdleStateAwareChannelHandler.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e) |
void |
IdleStateAwareChannelUpstreamHandler.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e) |
void |
IdleStateHandler.messageReceived(ChannelHandlerContext ctx,
MessageEvent e) |
void |
ReadTimeoutHandler.messageReceived(ChannelHandlerContext ctx,
MessageEvent e) |
protected void |
ReadTimeoutHandler.readTimedOut(ChannelHandlerContext ctx) |
void |
IdleStateHandler.writeComplete(ChannelHandlerContext ctx,
WriteCompletionEvent e) |
void |
WriteTimeoutHandler.writeRequested(ChannelHandlerContext ctx,
MessageEvent e) |
protected void |
WriteTimeoutHandler.writeTimedOut(ChannelHandlerContext ctx) |
Modifier and Type | Method and Description |
---|---|
void |
GlobalTrafficShapingHandler.channelClosed(ChannelHandlerContext ctx,
ChannelStateEvent e) |
void |
ChannelTrafficShapingHandler.channelClosed(ChannelHandlerContext ctx,
ChannelStateEvent e) |
void |
GlobalChannelTrafficShapingHandler.channelClosed(ChannelHandlerContext ctx,
ChannelStateEvent e) |
void |
GlobalTrafficShapingHandler.channelConnected(ChannelHandlerContext ctx,
ChannelStateEvent e) |
void |
ChannelTrafficShapingHandler.channelConnected(ChannelHandlerContext ctx,
ChannelStateEvent e) |
void |
AbstractTrafficShapingHandler.channelConnected(ChannelHandlerContext ctx,
ChannelStateEvent e) |
void |
GlobalChannelTrafficShapingHandler.channelConnected(ChannelHandlerContext ctx,
ChannelStateEvent e) |
protected long |
GlobalChannelTrafficShapingHandler.checkWaitReadTime(ChannelHandlerContext ctx,
long wait,
long now) |
protected void |
GlobalChannelTrafficShapingHandler.informReadOperation(ChannelHandlerContext ctx,
long now) |
protected void |
AbstractTrafficShapingHandler.internalSubmitWrite(ChannelHandlerContext ctx,
MessageEvent evt)
Deprecated.
|
void |
AbstractTrafficShapingHandler.messageReceived(ChannelHandlerContext ctx,
MessageEvent evt) |
void |
GlobalChannelTrafficShapingHandler.messageReceived(ChannelHandlerContext ctx,
MessageEvent evt) |
protected void |
AbstractTrafficShapingHandler.submitWrite(ChannelHandlerContext ctx,
MessageEvent evt,
long delay)
Deprecated.
|
protected void |
GlobalChannelTrafficShapingHandler.submitWrite(ChannelHandlerContext ctx,
MessageEvent evt,
long size,
long writedelay,
long now) |
void |
AbstractTrafficShapingHandler.writeRequested(ChannelHandlerContext ctx,
MessageEvent evt) |
void |
GlobalChannelTrafficShapingHandler.writeRequested(ChannelHandlerContext ctx,
MessageEvent evt) |
Copyright © 2008–2023 The Netty Project. All rights reserved.