| Package | Description |
|---|---|
| org.jboss.netty.bootstrap |
IoC/DI friendly helper classes which enable an easy implementation of
typical client side and server side channel initialization.
|
| 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.channel.socket.http |
An HTTP-based client-side
SocketChannel
and its corresponding server-side Servlet implementation that make your
existing server application work in a firewalled network. |
| 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
ChannelBuffers
in a compression format such as zlib
and gzip. |
| org.jboss.netty.handler.codec.embedder |
A helper that wraps an encoder or a decoder so that they can be used without
doing actual I/O in unit tests or higher level codecs.
|
| 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 |
SSL ·
TLS implementation based on
SSLEngine |
| 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 |
|---|---|
void |
ServerBootstrap.Binder.channelOpen(ChannelHandlerContext ctx,
ChannelStateEvent evt) |
void |
ServerBootstrap.Binder.childChannelOpen(ChannelHandlerContext ctx,
ChildChannelStateEvent e) |
void |
ServerBootstrap.Binder.exceptionCaught(ChannelHandlerContext ctx,
ExceptionEvent e) |
| Modifier and Type | Class and Description |
|---|---|
private class |
DefaultChannelPipeline.DefaultChannelHandlerContext |
| 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(java.lang.Class<? extends ChannelHandler> handlerType)
Returns the context object of the
ChannelHandler of the
specified type in this pipeline. |
ChannelHandlerContext |
DefaultChannelPipeline.getContext(java.lang.Class<? extends ChannelHandler> handlerType) |
ChannelHandlerContext |
ChannelPipeline.getContext(java.lang.String name)
Returns the context object of the
ChannelHandler with the
specified name in this pipeline. |
ChannelHandlerContext |
DefaultChannelPipeline.getContext(java.lang.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,
java.net.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 |
SimpleChannelDownstreamHandler.bindRequested(ChannelHandlerContext ctx,
ChannelStateEvent e)
Invoked when
Channel.bind(SocketAddress) was called. |
void |
SimpleChannelHandler.bindRequested(ChannelHandlerContext ctx,
ChannelStateEvent e)
Invoked when
Channel.bind(SocketAddress) was called. |
private void |
DefaultChannelPipeline.callAfterAdd(ChannelHandlerContext ctx) |
private static void |
DefaultChannelPipeline.callAfterRemove(ChannelHandlerContext ctx) |
private static void |
DefaultChannelPipeline.callBeforeAdd(ChannelHandlerContext ctx) |
private static void |
DefaultChannelPipeline.callBeforeRemove(ChannelHandlerContext ctx) |
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 |
SimpleChannelDownstreamHandler.closeRequested(ChannelHandlerContext ctx,
ChannelStateEvent e)
Invoked when
Channel.close() was called. |
void |
SimpleChannelHandler.closeRequested(ChannelHandlerContext ctx,
ChannelStateEvent e)
Invoked when
Channel.close() was called. |
static void |
Channels.connect(ChannelHandlerContext ctx,
ChannelFuture future,
java.net.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 |
SimpleChannelDownstreamHandler.connectRequested(ChannelHandlerContext ctx,
ChannelStateEvent e)
Invoked when
Channel.connect(SocketAddress) was called. |
void |
SimpleChannelHandler.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 |
SimpleChannelDownstreamHandler.disconnectRequested(ChannelHandlerContext ctx,
ChannelStateEvent e)
Invoked when
Channel.disconnect() was called. |
void |
SimpleChannelHandler.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,
java.net.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,
java.net.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,
java.lang.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,
java.lang.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,
java.lang.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,
java.lang.Object message,
java.net.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 |
ChannelDownstreamHandler.handleDownstream(ChannelHandlerContext ctx,
ChannelEvent e)
Handles the specified downstream event.
|
void |
SimpleChannelDownstreamHandler.handleDownstream(ChannelHandlerContext ctx,
ChannelEvent e)
Handles the specified downstream event.
|
void |
SimpleChannelHandler.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 |
SimpleChannelDownstreamHandler.setInterestOpsRequested(ChannelHandlerContext ctx,
ChannelStateEvent e)
Invoked when
Channel.setInterestOps(int) was called. |
void |
SimpleChannelHandler.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 |
SimpleChannelDownstreamHandler.unbindRequested(ChannelHandlerContext ctx,
ChannelStateEvent e)
Invoked when
Channel.unbind() was called. |
void |
SimpleChannelHandler.unbindRequested(ChannelHandlerContext ctx,
ChannelStateEvent e)
Invoked when
Channel.unbind() was called. |
static void |
Channels.write(ChannelHandlerContext ctx,
ChannelFuture future,
java.lang.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,
java.lang.Object message,
java.net.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 |
SimpleChannelDownstreamHandler.writeRequested(ChannelHandlerContext ctx,
MessageEvent e)
Invoked when
Channel.write(Object) is called. |
void |
SimpleChannelHandler.writeRequested(ChannelHandlerContext ctx,
MessageEvent e)
Invoked when
Channel.write(Object) is called. |
| Modifier and Type | Method and Description |
|---|---|
void |
HttpTunnelingClientSocketChannel.ServletChannelHandler.channelBound(ChannelHandlerContext ctx,
ChannelStateEvent e) |
void |
HttpTunnelingClientSocketChannel.ServletChannelHandler.channelClosed(ChannelHandlerContext ctx,
ChannelStateEvent e) |
void |
HttpTunnelingClientSocketChannel.ServletChannelHandler.channelDisconnected(ChannelHandlerContext ctx,
ChannelStateEvent e) |
void |
HttpTunnelingClientSocketChannel.ServletChannelHandler.channelInterestChanged(ChannelHandlerContext ctx,
ChannelStateEvent e) |
void |
HttpTunnelingClientSocketChannel.ServletChannelHandler.channelUnbound(ChannelHandlerContext ctx,
ChannelStateEvent e) |
void |
HttpTunnelingClientSocketChannel.ServletChannelHandler.exceptionCaught(ChannelHandlerContext ctx,
ExceptionEvent e) |
void |
HttpTunnelingServlet.OutboundConnectionHandler.exceptionCaught(ChannelHandlerContext ctx,
ExceptionEvent e) |
void |
HttpTunnelingClientSocketChannel.ServletChannelHandler.messageReceived(ChannelHandlerContext ctx,
MessageEvent e) |
void |
HttpTunnelingServlet.OutboundConnectionHandler.messageReceived(ChannelHandlerContext ctx,
MessageEvent e) |
| 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) |
private static void |
HttpStaticFileServerHandler.sendError(ChannelHandlerContext ctx,
HttpResponseStatus status) |
private static void |
HttpStaticFileServerHandler.sendNotModified(ChannelHandlerContext ctx)
When file timestamp is the same as what the browser is sending up, send a "304 Not Modified"
|
| 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 |
HttpSnoopClientHandler.messageReceived(ChannelHandlerContext ctx,
MessageEvent e) |
void |
HttpSnoopServerHandler.messageReceived(ChannelHandlerContext ctx,
MessageEvent e) |
| Modifier and Type | Method and Description |
|---|---|
void |
HttpUploadServerHandler.channelClosed(ChannelHandlerContext ctx,
ChannelStateEvent e) |
void |
HttpUploadClientHandler.exceptionCaught(ChannelHandlerContext ctx,
ExceptionEvent e) |
void |
HttpUploadServerHandler.exceptionCaught(ChannelHandlerContext ctx,
ExceptionEvent e) |
void |
HttpUploadClientHandler.messageReceived(ChannelHandlerContext ctx,
MessageEvent e) |
void |
HttpUploadServerHandler.messageReceived(ChannelHandlerContext ctx,
MessageEvent e) |
| Modifier and Type | Method and Description |
|---|---|
void |
AutobahnServerHandler.exceptionCaught(ChannelHandlerContext ctx,
ExceptionEvent e) |
private void |
AutobahnServerHandler.handleHttpRequest(ChannelHandlerContext ctx,
HttpRequest req) |
private void |
AutobahnServerHandler.handleWebSocketFrame(ChannelHandlerContext ctx,
WebSocketFrame frame) |
void |
AutobahnServerHandler.messageReceived(ChannelHandlerContext ctx,
MessageEvent e) |
private static void |
AutobahnServerHandler.sendHttpResponse(ChannelHandlerContext ctx,
HttpRequest req,
HttpResponse res) |
| 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) |
private void |
WebSocketServerHandler.handleHttpRequest(ChannelHandlerContext ctx,
HttpRequest req) |
private void |
WebSocketServerHandler.handleWebSocketFrame(ChannelHandlerContext ctx,
WebSocketFrame frame) |
void |
WebSocketServerHandler.messageReceived(ChannelHandlerContext ctx,
MessageEvent e) |
private static void |
WebSocketServerHandler.sendHttpResponse(ChannelHandlerContext ctx,
HttpRequest req,
HttpResponse res) |
| 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 java.lang.Object |
PortUnificationServerHandler.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer) |
private void |
PortUnificationServerHandler.enableGzip(ChannelHandlerContext ctx) |
private void |
PortUnificationServerHandler.enableSsl(ChannelHandlerContext ctx) |
private void |
PortUnificationServerHandler.switchToFactorial(ChannelHandlerContext ctx) |
private void |
PortUnificationServerHandler.switchToHttp(ChannelHandlerContext ctx) |
| Modifier and Type | Method and Description |
|---|---|
void |
HexDumpProxyInboundHandler.channelClosed(ChannelHandlerContext ctx,
ChannelStateEvent e) |
void |
HexDumpProxyInboundHandler.OutboundHandler.channelClosed(ChannelHandlerContext ctx,
ChannelStateEvent e) |
void |
HexDumpProxyInboundHandler.channelInterestChanged(ChannelHandlerContext ctx,
ChannelStateEvent e) |
void |
HexDumpProxyInboundHandler.OutboundHandler.channelInterestChanged(ChannelHandlerContext ctx,
ChannelStateEvent e) |
void |
HexDumpProxyInboundHandler.channelOpen(ChannelHandlerContext ctx,
ChannelStateEvent e) |
void |
HexDumpProxyInboundHandler.exceptionCaught(ChannelHandlerContext ctx,
ExceptionEvent e) |
void |
HexDumpProxyInboundHandler.OutboundHandler.exceptionCaught(ChannelHandlerContext ctx,
ExceptionEvent e) |
void |
HexDumpProxyInboundHandler.messageReceived(ChannelHandlerContext ctx,
MessageEvent e) |
void |
HexDumpProxyInboundHandler.OutboundHandler.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 |
SecureChatClientHandler.exceptionCaught(ChannelHandlerContext ctx,
ExceptionEvent e) |
void |
SecureChatServerHandler.exceptionCaught(ChannelHandlerContext ctx,
ExceptionEvent e) |
void |
SecureChatClientHandler.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e) |
void |
SecureChatServerHandler.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e) |
void |
SecureChatClientHandler.messageReceived(ChannelHandlerContext ctx,
MessageEvent e) |
void |
SecureChatServerHandler.messageReceived(ChannelHandlerContext ctx,
MessageEvent e) |
| Modifier and Type | Method and Description |
|---|---|
void |
TelnetServerHandler.channelConnected(ChannelHandlerContext ctx,
ChannelStateEvent e) |
void |
TelnetClientHandler.exceptionCaught(ChannelHandlerContext ctx,
ExceptionEvent e) |
void |
TelnetServerHandler.exceptionCaught(ChannelHandlerContext ctx,
ExceptionEvent e) |
void |
TelnetClientHandler.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e) |
void |
TelnetServerHandler.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e) |
void |
TelnetClientHandler.messageReceived(ChannelHandlerContext ctx,
MessageEvent e) |
void |
TelnetServerHandler.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 java.lang.Object |
Base64Decoder.decode(ChannelHandlerContext ctx,
Channel channel,
java.lang.Object msg) |
protected java.lang.Object |
Base64Encoder.encode(ChannelHandlerContext ctx,
Channel channel,
java.lang.Object msg) |
| Modifier and Type | Field and Description |
|---|---|
private ChannelHandlerContext |
JdkZlibEncoder.ctx |
private ChannelHandlerContext |
ZlibEncoder.ctx |
| Modifier and Type | Method and Description |
|---|---|
void |
JdkZlibEncoder.afterAdd(ChannelHandlerContext ctx) |
void |
ZlibEncoder.afterAdd(ChannelHandlerContext ctx) |
void |
JdkZlibEncoder.afterRemove(ChannelHandlerContext ctx) |
void |
ZlibEncoder.afterRemove(ChannelHandlerContext ctx) |
void |
JdkZlibEncoder.beforeAdd(ChannelHandlerContext ctx) |
void |
ZlibEncoder.beforeAdd(ChannelHandlerContext ctx) |
void |
JdkZlibEncoder.beforeRemove(ChannelHandlerContext ctx) |
void |
ZlibEncoder.beforeRemove(ChannelHandlerContext ctx) |
protected java.lang.Object |
ZlibDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
java.lang.Object msg) |
protected java.lang.Object |
JdkZlibEncoder.encode(ChannelHandlerContext ctx,
Channel channel,
java.lang.Object msg) |
protected java.lang.Object |
ZlibEncoder.encode(ChannelHandlerContext ctx,
Channel channel,
java.lang.Object msg) |
private ChannelFuture |
JdkZlibEncoder.finishEncode(ChannelHandlerContext ctx,
ChannelEvent evt) |
private ChannelFuture |
ZlibEncoder.finishEncode(ChannelHandlerContext ctx,
ChannelEvent evt) |
void |
JdkZlibEncoder.handleDownstream(ChannelHandlerContext ctx,
ChannelEvent evt) |
void |
ZlibEncoder.handleDownstream(ChannelHandlerContext ctx,
ChannelEvent evt) |
| Modifier and Type | Method and Description |
|---|---|
void |
AbstractCodecEmbedder.EmbeddedChannelSink.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e) |
| Modifier and Type | Field and Description |
|---|---|
private ChannelHandlerContext |
FrameDecoder.ctx |
| 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) |
private void |
FrameDecoder.callDecode(ChannelHandlerContext context,
Channel channel,
ChannelBuffer cumulation,
java.net.SocketAddress remoteAddress) |
void |
FrameDecoder.channelClosed(ChannelHandlerContext ctx,
ChannelStateEvent e) |
void |
FrameDecoder.channelDisconnected(ChannelHandlerContext ctx,
ChannelStateEvent e) |
protected void |
FrameDecoder.cleanup(ChannelHandlerContext ctx,
ChannelStateEvent e)
|
protected java.lang.Object |
DelimiterBasedFrameDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer) |
protected java.lang.Object |
FixedLengthFrameDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer) |
protected abstract java.lang.Object |
FrameDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer)
Decodes the received packets so far into a frame.
|
protected java.lang.Object |
LengthFieldBasedFrameDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer) |
protected java.lang.Object |
LineBasedFrameDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer) |
protected java.lang.Object |
FrameDecoder.decodeLast(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer)
Decodes the received data so far into a frame when the channel is
disconnected.
|
protected java.lang.Object |
LengthFieldPrepender.encode(ChannelHandlerContext ctx,
Channel channel,
java.lang.Object msg) |
void |
FrameDecoder.exceptionCaught(ChannelHandlerContext ctx,
ExceptionEvent e) |
private void |
LineBasedFrameDecoder.fail(ChannelHandlerContext ctx,
int length) |
private void |
DelimiterBasedFrameDecoder.fail(ChannelHandlerContext ctx,
long frameLength) |
private void |
LengthFieldBasedFrameDecoder.fail(ChannelHandlerContext ctx,
long frameLength) |
private void |
LineBasedFrameDecoder.fail(ChannelHandlerContext ctx,
java.lang.String length) |
private void |
LengthFieldBasedFrameDecoder.failIfNecessary(ChannelHandlerContext ctx,
boolean firstDetectionOfTooLongFrame) |
void |
FrameDecoder.messageReceived(ChannelHandlerContext ctx,
MessageEvent e) |
protected ChannelBuffer |
FixedLengthFrameDecoder.newCumulationBuffer(ChannelHandlerContext ctx,
int minimumCapacity) |
protected ChannelBuffer |
FrameDecoder.newCumulationBuffer(ChannelHandlerContext ctx,
int minimumCapacity)
Create a new
ChannelBuffer which is used for the cumulation. |
protected void |
FrameDecoder.unfoldAndFireMessageReceived(ChannelHandlerContext context,
java.net.SocketAddress remoteAddress,
java.lang.Object result) |
protected ChannelBuffer |
FrameDecoder.updateCumulation(ChannelHandlerContext ctx,
ChannelBuffer input) |
| Modifier and Type | Field and Description |
|---|---|
private ChannelHandlerContext |
HttpChunkAggregator.ctx |
| 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 java.lang.Object |
WebSocket00FrameDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer,
VoidEnum state) |
protected java.lang.Object |
WebSocket08FrameDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer,
WebSocket08FrameDecoder.State state) |
protected java.lang.Object |
WebSocketFrameAggregator.decode(ChannelHandlerContext ctx,
Channel channel,
java.lang.Object message) |
protected java.lang.Object |
WebSocket00FrameEncoder.encode(ChannelHandlerContext ctx,
Channel channel,
java.lang.Object msg) |
protected java.lang.Object |
WebSocket08FrameEncoder.encode(ChannelHandlerContext ctx,
Channel channel,
java.lang.Object msg) |
void |
WebSocketServerProtocolHandler.exceptionCaught(ChannelHandlerContext ctx,
ExceptionEvent e) |
void |
WebSocketServerProtocolHandshakeHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
(package private) static WebSocketServerHandshaker |
WebSocketServerProtocolHandler.getHandshaker(ChannelHandlerContext ctx) |
void |
WebSocketServerProtocolHandler.messageReceived(ChannelHandlerContext ctx,
MessageEvent e) |
void |
WebSocketServerProtocolHandshakeHandler.messageReceived(ChannelHandlerContext ctx,
MessageEvent e) |
private static void |
WebSocketServerProtocolHandshakeHandler.sendHttpResponse(ChannelHandlerContext ctx,
HttpRequest req,
HttpResponse res) |
(package private) static void |
WebSocketServerProtocolHandler.setHandshaker(ChannelHandlerContext ctx,
WebSocketServerHandshaker handshaker) |
| Modifier and Type | Method and Description |
|---|---|
protected java.lang.Object |
MarshallingDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer) |
protected java.lang.Object |
CompatibleMarshallingDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer,
VoidEnum state) |
protected java.lang.Object |
CompatibleMarshallingDecoder.decodeLast(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer,
VoidEnum state) |
protected java.lang.Object |
CompatibleMarshallingEncoder.encode(ChannelHandlerContext ctx,
Channel channel,
java.lang.Object msg) |
protected java.lang.Object |
MarshallingEncoder.encode(ChannelHandlerContext ctx,
Channel channel,
java.lang.Object msg) |
void |
CompatibleMarshallingDecoder.exceptionCaught(ChannelHandlerContext ctx,
ExceptionEvent e)
Calls
Channel.close() if a TooLongFrameException was thrown |
org.jboss.marshalling.Marshaller |
DefaultMarshallerProvider.getMarshaller(ChannelHandlerContext ctx) |
org.jboss.marshalling.Marshaller |
MarshallerProvider.getMarshaller(ChannelHandlerContext ctx)
Get a
Marshaller for the given ChannelHandlerContext |
org.jboss.marshalling.Marshaller |
ThreadLocalMarshallerProvider.getMarshaller(ChannelHandlerContext ctx) |
org.jboss.marshalling.Unmarshaller |
ContextBoundUnmarshallerProvider.getUnmarshaller(ChannelHandlerContext ctx) |
org.jboss.marshalling.Unmarshaller |
DefaultUnmarshallerProvider.getUnmarshaller(ChannelHandlerContext ctx) |
org.jboss.marshalling.Unmarshaller |
ThreadLocalUnmarshallerProvider.getUnmarshaller(ChannelHandlerContext ctx) |
org.jboss.marshalling.Unmarshaller |
UnmarshallerProvider.getUnmarshaller(ChannelHandlerContext ctx)
Get the
Unmarshaller for the given ChannelHandlerContext |
| Modifier and Type | Method and Description |
|---|---|
protected abstract java.lang.Object |
OneToOneDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
java.lang.Object msg)
Transforms the specified received message into another message and return
the transformed message.
|
protected boolean |
OneToOneEncoder.doEncode(ChannelHandlerContext ctx,
MessageEvent e) |
protected boolean |
OneToOneStrictEncoder.doEncode(ChannelHandlerContext ctx,
MessageEvent e) |
protected abstract java.lang.Object |
OneToOneEncoder.encode(ChannelHandlerContext ctx,
Channel channel,
java.lang.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 java.lang.Object |
ProtobufVarint32FrameDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer) |
protected java.lang.Object |
ProtobufDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
java.lang.Object msg) |
protected java.lang.Object |
ProtobufEncoder.encode(ChannelHandlerContext ctx,
Channel channel,
java.lang.Object msg) |
protected java.lang.Object |
ProtobufVarint32LengthFieldPrepender.encode(ChannelHandlerContext ctx,
Channel channel,
java.lang.Object msg) |
| Modifier and Type | Method and Description |
|---|---|
private void |
ReplayingDecoder.callDecode(ChannelHandlerContext context,
Channel channel,
ChannelBuffer input,
ChannelBuffer replayableInput,
java.net.SocketAddress remoteAddress) |
protected void |
ReplayingDecoder.cleanup(ChannelHandlerContext ctx,
ChannelStateEvent e) |
protected java.lang.Object |
ReplayingDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer)
|
protected abstract java.lang.Object |
ReplayingDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer,
T state)
Decodes the received packets so far into a frame.
|
protected java.lang.Object |
ReplayingDecoder.decodeLast(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer) |
protected java.lang.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 java.lang.Object |
RtspMessageDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer,
HttpMessageDecoder.State state) |
protected java.lang.Object |
RtspMessageEncoder.encode(ChannelHandlerContext ctx,
Channel channel,
java.lang.Object msg) |
| Modifier and Type | Method and Description |
|---|---|
private ChannelBuffer |
CompatibleObjectEncoder.buffer(ChannelHandlerContext ctx) |
protected java.lang.Object |
ObjectDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer) |
protected java.lang.Object |
CompatibleObjectEncoder.encode(ChannelHandlerContext context,
Channel channel,
java.lang.Object msg) |
protected java.lang.Object |
ObjectEncoder.encode(ChannelHandlerContext ctx,
Channel channel,
java.lang.Object msg) |
| Modifier and Type | Method and Description |
|---|---|
protected java.lang.Object |
SocksAuthRequestDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer,
SocksAuthRequestDecoder.State state) |
protected java.lang.Object |
SocksAuthResponseDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer,
SocksAuthResponseDecoder.State state) |
protected java.lang.Object |
SocksCmdRequestDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer,
SocksCmdRequestDecoder.State state) |
protected java.lang.Object |
SocksCmdResponseDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer,
SocksCmdResponseDecoder.State state) |
protected java.lang.Object |
SocksInitRequestDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer,
SocksInitRequestDecoder.State state) |
protected java.lang.Object |
SocksInitResponseDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer,
SocksInitResponseDecoder.State state) |
protected java.lang.Object |
SocksMessageEncoder.encode(ChannelHandlerContext ctx,
Channel channel,
java.lang.Object msg) |
| Modifier and Type | Field and Description |
|---|---|
private ChannelHandlerContext |
SpdyFrameCodec.ctx |
private ChannelHandlerContext |
SpdyHttpEncoder.SpdyFrameWriter.ctx |
private ChannelHandlerContext |
SpdySessionHandler.ClosingChannelFutureListener.ctx |
| 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 java.lang.Object |
SpdyFrameCodec.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer) |
protected java.lang.Object |
SpdyHttpDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
java.lang.Object msg) |
void |
SpdySessionHandler.exceptionCaught(ChannelHandlerContext ctx,
ExceptionEvent e) |
private static ChannelFuture |
SpdyHttpEncoder.getDataFuture(ChannelHandlerContext ctx,
ChannelFuture future,
SpdyDataFrame[] spdyDataFrames,
java.net.SocketAddress remoteAddress) |
private ChannelFuture |
SpdyHttpEncoder.getMessageFuture(ChannelHandlerContext ctx,
MessageEvent e,
int streamId,
HttpMessage httpMessage) |
void |
SpdyFrameCodec.handleDownstream(ChannelHandlerContext ctx,
ChannelEvent evt) |
void |
SpdyHttpCodec.handleDownstream(ChannelHandlerContext ctx,
ChannelEvent e) |
void |
SpdyHttpEncoder.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) |
private void |
SpdySessionHandler.issueSessionError(ChannelHandlerContext ctx,
Channel channel,
java.net.SocketAddress remoteAddress,
SpdySessionStatus status) |
private void |
SpdySessionHandler.issueStreamError(ChannelHandlerContext ctx,
java.net.SocketAddress remoteAddress,
int streamId,
SpdyStreamStatus status) |
void |
SpdyHttpResponseStreamIdHandler.messageReceived(ChannelHandlerContext ctx,
MessageEvent e) |
void |
SpdySessionHandler.messageReceived(ChannelHandlerContext ctx,
MessageEvent e) |
private ChannelFuture |
SpdySessionHandler.sendGoAwayFrame(ChannelHandlerContext ctx,
Channel channel,
java.net.SocketAddress remoteAddress,
SpdySessionStatus status) |
private void |
SpdySessionHandler.sendGoAwayFrame(ChannelHandlerContext ctx,
ChannelStateEvent e) |
private void |
SpdySessionHandler.updateSendWindowSize(ChannelHandlerContext ctx,
int streamId,
int deltaWindowSize) |
protected void |
SpdyHttpEncoder.writeChunk(ChannelHandlerContext ctx,
ChannelFuture future,
int streamId,
HttpChunk chunk,
java.net.SocketAddress remoteAddress)
Writes an HTTP chunk downstream as one or more SPDY frames.
|
void |
SpdyHttpResponseStreamIdHandler.writeRequested(ChannelHandlerContext ctx,
MessageEvent e) |
| Constructor and Description |
|---|
ClosingChannelFutureListener(ChannelHandlerContext ctx,
ChannelStateEvent e) |
SpdyFrameWriter(ChannelHandlerContext ctx,
MessageEvent e) |
| Modifier and Type | Method and Description |
|---|---|
protected java.lang.Object |
StringDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
java.lang.Object msg) |
protected java.lang.Object |
StringEncoder.encode(ChannelHandlerContext ctx,
Channel channel,
java.lang.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,
java.util.concurrent.Executor executor) |
ChannelEventRunnable(ChannelHandlerContext ctx,
ChannelEvent e,
java.util.concurrent.Executor executor)
Creates a
Runnable which sends the specified ChannelEvent
upstream via the specified ChannelHandlerContext. |
ChannelUpstreamEventRunnable(ChannelHandlerContext ctx,
ChannelEvent e,
java.util.concurrent.Executor executor)
Creates a
Runnable which sends the specified ChannelEvent
upstream via the specified ChannelHandlerContext. |
| Modifier and Type | Method and Description |
|---|---|
protected boolean |
IpFilterRuleHandler.accept(ChannelHandlerContext ctx,
ChannelEvent e,
java.net.InetSocketAddress inetSocketAddress) |
protected abstract boolean |
IpFilteringHandlerImpl.accept(ChannelHandlerContext ctx,
ChannelEvent e,
java.net.InetSocketAddress inetSocketAddress)
Called when the channel is connected.
|
protected boolean |
OneIpFilterHandler.accept(ChannelHandlerContext ctx,
ChannelEvent e,
java.net.InetSocketAddress inetSocketAddress) |
ChannelFuture |
IpFilterListener.allowed(ChannelHandlerContext ctx,
ChannelEvent e,
java.net.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,
java.net.InetSocketAddress inetSocketAddress) |
protected ChannelFuture |
IpFilteringHandlerImpl.handleRefusedChannel(ChannelHandlerContext ctx,
ChannelEvent e,
java.net.InetSocketAddress inetSocketAddress)
Called when the channel has the CONNECTED status and the channel was refused by a previous call to accept().
|
void |
IpFilteringHandlerImpl.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e) |
void |
OneIpFilterHandler.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,
java.net.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 | Field and Description |
|---|---|
private ChannelHandlerContext |
BufferedWriteHandler.ctx |
| 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 | Field and Description |
|---|---|
private ChannelHandlerContext |
SslHandler.ClosingChannelFutureListener.context |
private ChannelHandlerContext |
SslHandler.ctx |
| 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) |
private void |
SslHandler.closeOutboundAndChannel(ChannelHandlerContext context,
ChannelStateEvent e) |
protected java.lang.Object |
SslHandler.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer in) |
void |
SslHandler.exceptionCaught(ChannelHandlerContext ctx,
ExceptionEvent e) |
private void |
SslHandler.flushPendingEncryptedWrites(ChannelHandlerContext ctx) |
void |
SslHandler.handleDownstream(ChannelHandlerContext context,
ChannelEvent evt) |
private ChannelBuffer |
SslHandler.unwrap(ChannelHandlerContext ctx,
Channel channel,
java.nio.ByteBuffer nioInNetBuf,
int initialNettyOutAppBufCapacity,
boolean mightNeedHandshake)
Unwraps inbound SSL records.
|
private void |
SslHandler.unwrapNonAppData(ChannelHandlerContext ctx,
Channel channel,
boolean mightNeedHandshake)
Calls
SSLEngine.unwrap(ByteBuffer, ByteBuffer) with an empty buffer to handle handshakes, etc. |
private void |
SslHandler.wrap(ChannelHandlerContext context,
Channel channel) |
private ChannelFuture |
SslHandler.wrapNonAppData(ChannelHandlerContext ctx,
Channel channel) |
| Constructor and Description |
|---|
ClosingChannelFutureListener(ChannelHandlerContext context,
ChannelStateEvent e) |
| Modifier and Type | Field and Description |
|---|---|
private ChannelHandlerContext |
ChunkedWriteHandler.ctx |
| 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) |
private void |
ChunkedWriteHandler.discard(ChannelHandlerContext ctx,
boolean fireNow) |
private void |
ChunkedWriteHandler.flush(ChannelHandlerContext ctx,
boolean fireNow) |
void |
ChunkedWriteHandler.handleDownstream(ChannelHandlerContext ctx,
ChannelEvent e) |
void |
ChunkedWriteHandler.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e) |
| Modifier and Type | Field and Description |
|---|---|
private ChannelHandlerContext |
IdleStateHandler.ReaderIdleTimeoutTask.ctx |
private ChannelHandlerContext |
IdleStateHandler.WriterIdleTimeoutTask.ctx |
private ChannelHandlerContext |
IdleStateHandler.AllIdleTimeoutTask.ctx |
private ChannelHandlerContext |
ReadTimeoutHandler.ReadTimeoutTask.ctx |
private ChannelHandlerContext |
WriteTimeoutHandler.WriteTimeoutTask.ctx |
| 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) |
private static void |
IdleStateHandler.destroy(ChannelHandlerContext ctx) |
private static void |
ReadTimeoutHandler.destroy(ChannelHandlerContext ctx) |
private void |
IdleStateHandler.fireChannelIdle(ChannelHandlerContext ctx,
IdleState state,
long lastActivityTimeMillis) |
private void |
ReadTimeoutHandler.ReadTimeoutTask.fireReadTimedOut(ChannelHandlerContext ctx) |
private void |
WriteTimeoutHandler.WriteTimeoutTask.fireWriteTimeOut(ChannelHandlerContext ctx) |
void |
IdleStateAwareChannelHandler.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e) |
void |
IdleStateAwareChannelUpstreamHandler.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e) |
private void |
IdleStateHandler.initialize(ChannelHandlerContext ctx) |
private void |
ReadTimeoutHandler.initialize(ChannelHandlerContext ctx) |
void |
IdleStateHandler.messageReceived(ChannelHandlerContext ctx,
MessageEvent e) |
void |
ReadTimeoutHandler.messageReceived(ChannelHandlerContext ctx,
MessageEvent e) |
protected void |
ReadTimeoutHandler.readTimedOut(ChannelHandlerContext ctx) |
private static IdleStateHandler.State |
IdleStateHandler.state(ChannelHandlerContext ctx) |
private static ReadTimeoutHandler.State |
ReadTimeoutHandler.state(ChannelHandlerContext ctx) |
void |
IdleStateHandler.writeComplete(ChannelHandlerContext ctx,
WriteCompletionEvent e) |
void |
WriteTimeoutHandler.writeRequested(ChannelHandlerContext ctx,
MessageEvent e) |
protected void |
WriteTimeoutHandler.writeTimedOut(ChannelHandlerContext ctx) |
| Constructor and Description |
|---|
AllIdleTimeoutTask(ChannelHandlerContext ctx) |
ReaderIdleTimeoutTask(ChannelHandlerContext ctx) |
ReadTimeoutTask(ChannelHandlerContext ctx) |
WriterIdleTimeoutTask(ChannelHandlerContext ctx) |
WriteTimeoutTask(ChannelHandlerContext ctx,
ChannelFuture future) |
| Modifier and Type | Field and Description |
|---|---|
(package private) ChannelHandlerContext |
AbstractTrafficShapingHandler.ReopenReadTimerTask.ctx |
private ChannelHandlerContext |
ChannelTrafficShapingHandler.ctx |
(package private) ChannelHandlerContext |
GlobalTrafficShapingHandler.PerChannel.ctx |
| Modifier and Type | Method and Description |
|---|---|
void |
ChannelTrafficShapingHandler.channelClosed(ChannelHandlerContext ctx,
ChannelStateEvent e) |
void |
GlobalChannelTrafficShapingHandler.channelClosed(ChannelHandlerContext ctx,
ChannelStateEvent e) |
void |
GlobalTrafficShapingHandler.channelClosed(ChannelHandlerContext ctx,
ChannelStateEvent e) |
void |
AbstractTrafficShapingHandler.channelConnected(ChannelHandlerContext ctx,
ChannelStateEvent e) |
void |
ChannelTrafficShapingHandler.channelConnected(ChannelHandlerContext ctx,
ChannelStateEvent e) |
void |
GlobalChannelTrafficShapingHandler.channelConnected(ChannelHandlerContext ctx,
ChannelStateEvent e) |
void |
GlobalTrafficShapingHandler.channelConnected(ChannelHandlerContext ctx,
ChannelStateEvent e) |
(package private) static AbstractTrafficShapingHandler.ReadWriteStatus |
AbstractTrafficShapingHandler.checkAttachment(ChannelHandlerContext ctx) |
(package private) long |
AbstractTrafficShapingHandler.checkWaitReadTime(ChannelHandlerContext ctx,
long wait,
long now)
Method overridden in GTSH to take into account specific timer for the channel.
|
protected long |
GlobalChannelTrafficShapingHandler.checkWaitReadTime(ChannelHandlerContext ctx,
long wait,
long now) |
(package private) long |
GlobalTrafficShapingHandler.checkWaitReadTime(ChannelHandlerContext ctx,
long wait,
long now) |
(package private) void |
AbstractTrafficShapingHandler.checkWriteSuspend(ChannelHandlerContext ctx,
long delay,
long queueSize)
Check the writability according to delay and size for the channel.
|
private GlobalChannelTrafficShapingHandler.PerChannel |
GlobalChannelTrafficShapingHandler.getOrSetPerChannel(ChannelHandlerContext ctx) |
private GlobalTrafficShapingHandler.PerChannel |
GlobalTrafficShapingHandler.getOrSetPerChannel(ChannelHandlerContext ctx) |
(package private) void |
AbstractTrafficShapingHandler.informReadOperation(ChannelHandlerContext ctx,
long now)
Method overridden in GTSH to take into account specific timer for the channel.
|
protected void |
GlobalChannelTrafficShapingHandler.informReadOperation(ChannelHandlerContext ctx,
long now) |
(package private) void |
GlobalTrafficShapingHandler.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) |
(package private) void |
AbstractTrafficShapingHandler.releaseReadSuspended(ChannelHandlerContext ctx)
Release the Read suspension.
|
(package private) void |
AbstractTrafficShapingHandler.releaseWriteSuspended(ChannelHandlerContext ctx)
Explicitly release the Write suspended status.
|
private void |
GlobalChannelTrafficShapingHandler.sendAllValid(ChannelHandlerContext ctx,
GlobalChannelTrafficShapingHandler.PerChannel perChannel,
long now) |
private void |
GlobalTrafficShapingHandler.sendAllValid(ChannelHandlerContext ctx,
GlobalTrafficShapingHandler.PerChannel perChannel,
long now) |
private void |
ChannelTrafficShapingHandler.sendAllValid(ChannelHandlerContext ctx,
long now) |
(package private) void |
AbstractTrafficShapingHandler.setWritable(ChannelHandlerContext ctx,
boolean writable) |
protected void |
AbstractTrafficShapingHandler.submitWrite(ChannelHandlerContext ctx,
MessageEvent evt,
long delay)
Deprecated.
|
(package private) abstract void |
AbstractTrafficShapingHandler.submitWrite(ChannelHandlerContext ctx,
MessageEvent evt,
long size,
long delay,
long now) |
(package private) void |
ChannelTrafficShapingHandler.submitWrite(ChannelHandlerContext ctx,
MessageEvent evt,
long size,
long delay,
long now) |
protected void |
GlobalChannelTrafficShapingHandler.submitWrite(ChannelHandlerContext ctx,
MessageEvent evt,
long size,
long writedelay,
long now) |
(package private) void |
GlobalTrafficShapingHandler.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) |
| Constructor and Description |
|---|
ReopenReadTimerTask(ChannelHandlerContext ctx) |