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.channel.socket.nio |
NIO-based socket channel
API implementation - recommended for a large number of connections (>= 1000).
|
org.jboss.netty.channel.socket.oio |
Old blocking I/O based socket channel API implementation - recommended for
a small number of connections (< 1000).
|
org.jboss.netty.example.discard | |
org.jboss.netty.example.factorial | |
org.jboss.netty.example.localtime | |
org.jboss.netty.example.objectecho | |
org.jboss.netty.example.securechat | |
org.jboss.netty.example.telnet | |
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.http |
Encoder, decoder and their related message types for HTTP.
|
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.spdy |
Encoder, decoder, session handler and their related message types for the SPDY protocol.
|
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 | Interface and Description |
---|---|
interface |
ChannelStateEvent
A
ChannelEvent which represents the change of the Channel
state. |
interface |
ChildChannelStateEvent
A
ChannelEvent which represents the notification of the state of
a child Channel . |
interface |
ExceptionEvent
A
ChannelEvent which represents the notification of an exception
raised by a ChannelHandler or an I/O thread. |
interface |
MessageEvent
A
ChannelEvent which represents the transmission or reception of a
message. |
interface |
WriteCompletionEvent
A
ChannelEvent which represents the notification of the completion
of a write request on a Channel . |
Modifier and Type | Class and Description |
---|---|
class |
DefaultChildChannelStateEvent
The default
ChildChannelStateEvent implementation. |
class |
DefaultExceptionEvent
The default
ExceptionEvent implementation. |
class |
DefaultWriteCompletionEvent
The default
WriteCompletionEvent implementation. |
class |
DownstreamChannelStateEvent
The default downstream
ChannelStateEvent implementation. |
class |
DownstreamMessageEvent
The default downstream
MessageEvent implementation. |
class |
UpstreamChannelStateEvent
The default upstream
ChannelStateEvent implementation. |
class |
UpstreamMessageEvent
The default upstream
MessageEvent implementation. |
Modifier and Type | Method and Description |
---|---|
void |
ChannelSink.eventSunk(ChannelPipeline pipeline,
ChannelEvent e)
Invoked by
ChannelPipeline when a downstream ChannelEvent
has reached its terminal (the head of the pipeline). |
void |
ChannelSink.exceptionCaught(ChannelPipeline pipeline,
ChannelEvent e,
ChannelPipelineException cause)
Invoked by
ChannelPipeline when an exception was raised while
one of its ChannelHandler s process a ChannelEvent . |
void |
AbstractChannelSink.exceptionCaught(ChannelPipeline pipeline,
ChannelEvent event,
ChannelPipelineException cause)
Sends an
ExceptionEvent upstream with the specified
cause . |
void |
ChannelDownstreamHandler.handleDownstream(ChannelHandlerContext ctx,
ChannelEvent e)
Handles the specified downstream event.
|
void |
SimpleChannelHandler.handleDownstream(ChannelHandlerContext ctx,
ChannelEvent e)
Handles the specified downstream event.
|
void |
SimpleChannelDownstreamHandler.handleDownstream(ChannelHandlerContext ctx,
ChannelEvent e)
Handles the specified downstream event.
|
void |
SimpleChannelUpstreamHandler.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e)
Handles the specified upstream 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.
|
protected boolean |
AbstractChannelSink.isFireExceptionCaughtLater(ChannelEvent event,
Throwable actualCause)
Returns
true if and only if the specified actualCause , which was raised while
handling the specified event , must trigger an exceptionCaught() event in
an I/O thread. |
protected void |
StaticChannelPipeline.notifyHandlerException(ChannelEvent e,
Throwable t)
Deprecated.
|
protected void |
DefaultChannelPipeline.notifyHandlerException(ChannelEvent e,
Throwable t) |
void |
ChannelPipeline.sendDownstream(ChannelEvent e)
Sends the specified
ChannelEvent to the last
ChannelDownstreamHandler in this pipeline. |
void |
ChannelHandlerContext.sendDownstream(ChannelEvent e)
Sends the specified
ChannelEvent to the
ChannelDownstreamHandler which is placed in the closest
downstream from the handler associated with this context. |
void |
StaticChannelPipeline.sendDownstream(ChannelEvent e)
Deprecated.
|
void |
DefaultChannelPipeline.sendDownstream(ChannelEvent e) |
void |
ChannelPipeline.sendUpstream(ChannelEvent e)
Sends the specified
ChannelEvent to the first
ChannelUpstreamHandler in this pipeline. |
void |
ChannelHandlerContext.sendUpstream(ChannelEvent e)
Sends the specified
ChannelEvent to the
ChannelUpstreamHandler which is placed in the closest upstream
from the handler associated with this context. |
void |
StaticChannelPipeline.sendUpstream(ChannelEvent e)
Deprecated.
|
void |
DefaultChannelPipeline.sendUpstream(ChannelEvent e) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
AbstractNioChannelSink.isFireExceptionCaughtLater(ChannelEvent event,
Throwable actualCause) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
AbstractOioChannelSink.isFireExceptionCaughtLater(ChannelEvent event,
Throwable actualCause) |
Modifier and Type | Method and Description |
---|---|
void |
DiscardClientHandler.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e) |
void |
DiscardServerHandler.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e) |
Modifier and Type | Method and Description |
---|---|
void |
FactorialClientHandler.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e) |
void |
FactorialServerHandler.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e) |
Modifier and Type | Method and Description |
---|---|
void |
LocalTimeServerHandler.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e) |
void |
LocalTimeClientHandler.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e) |
Modifier and Type | Method and Description |
---|---|
void |
ObjectEchoServerHandler.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e) |
void |
ObjectEchoClientHandler.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e) |
Modifier and Type | Method and Description |
---|---|
void |
SecureChatClientHandler.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e) |
void |
SecureChatServerHandler.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e) |
Modifier and Type | Method and Description |
---|---|
void |
TelnetServerHandler.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e) |
void |
TelnetClientHandler.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e) |
Modifier and Type | Method and Description |
---|---|
void |
JdkZlibEncoder.handleDownstream(ChannelHandlerContext ctx,
ChannelEvent evt) |
void |
ZlibEncoder.handleDownstream(ChannelHandlerContext ctx,
ChannelEvent evt) |
Modifier and Type | Method and Description |
---|---|
void |
HttpServerCodec.handleDownstream(ChannelHandlerContext ctx,
ChannelEvent e) |
void |
HttpClientCodec.handleDownstream(ChannelHandlerContext ctx,
ChannelEvent e) |
void |
HttpServerCodec.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e) |
void |
HttpClientCodec.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e) |
Modifier and Type | Method and Description |
---|---|
void |
OneToOneEncoder.handleDownstream(ChannelHandlerContext ctx,
ChannelEvent evt) |
void |
OneToOneDecoder.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent evt) |
Modifier and Type | Method and Description |
---|---|
void |
SpdyHttpCodec.handleDownstream(ChannelHandlerContext ctx,
ChannelEvent e) |
void |
SpdyHttpEncoder.handleDownstream(ChannelHandlerContext ctx,
ChannelEvent evt) |
void |
SpdyFrameEncoder.handleDownstream(ChannelHandlerContext ctx,
ChannelEvent evt) |
void |
SpdyFrameCodec.handleDownstream(ChannelHandlerContext ctx,
ChannelEvent e) |
void |
SpdySessionHandler.handleDownstream(ChannelHandlerContext ctx,
ChannelEvent evt) |
void |
SpdyHttpCodec.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e) |
void |
SpdyOrHttpChooser.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e) |
void |
SpdyFrameCodec.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e) |
Modifier and Type | Field and Description |
---|---|
protected ChannelEvent |
ChannelEventRunnable.e |
Modifier and Type | Method and Description |
---|---|
ChannelEvent |
ChannelEventRunnable.getEvent()
Returns the
ChannelEvent which will be sent upstream. |
Modifier and Type | Method and Description |
---|---|
protected Executor |
OrderedMemoryAwareThreadPoolExecutor.getChildExecutor(ChannelEvent e) |
protected Executor |
OrderedDownstreamThreadPoolExecutor.getChildExecutor(ChannelEvent e) |
protected Object |
OrderedMemoryAwareThreadPoolExecutor.getChildExecutorKey(ChannelEvent e) |
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 abstract boolean |
IpFilteringHandlerImpl.accept(ChannelHandlerContext ctx,
ChannelEvent e,
InetSocketAddress inetSocketAddress)
Called when the channel is connected.
|
protected boolean |
OneIpFilterHandler.accept(ChannelHandlerContext ctx,
ChannelEvent e,
InetSocketAddress inetSocketAddress) |
protected boolean |
IpFilterRuleHandler.accept(ChannelHandlerContext ctx,
ChannelEvent e,
InetSocketAddress inetSocketAddress) |
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().
|
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. |
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 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 |
IpFilteringHandlerImpl.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e) |
void |
OneIpFilterHandler.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e) |
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) |
void |
LoggingHandler.log(ChannelEvent e)
Logs the specified event to the
InternalLogger returned by
LoggingHandler.getLogger() . |
Modifier and Type | Method and Description |
---|---|
ChannelEvent |
BlockingReadHandler.readEvent()
Waits until a new
ChannelEvent is received or the associated
Channel is closed. |
ChannelEvent |
BlockingReadHandler.readEvent(long timeout,
TimeUnit unit)
Waits until a new
ChannelEvent is received or the associated
Channel is closed. |
Modifier and Type | Method and Description |
---|---|
protected BlockingQueue<ChannelEvent> |
BlockingReadHandler.getQueue()
Returns the queue which stores the received messages.
|
Constructor and Description |
---|
BlockingReadHandler(BlockingQueue<ChannelEvent> queue)
Creates a new instance with the specified
BlockingQueue . |
Modifier and Type | Method and Description |
---|---|
void |
SslHandler.handleDownstream(ChannelHandlerContext context,
ChannelEvent evt) |
Modifier and Type | Method and Description |
---|---|
void |
ChunkedWriteHandler.handleDownstream(ChannelHandlerContext ctx,
ChannelEvent e) |
void |
ChunkedWriteHandler.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e) |
Modifier and Type | Interface and Description |
---|---|
interface |
IdleStateEvent
A
ChannelEvent that is triggered when a Channel has been idle
for a while. |
Modifier and Type | Class and Description |
---|---|
class |
DefaultIdleStateEvent
The default
IdleStateEvent implementation. |
Modifier and Type | Method and Description |
---|---|
void |
IdleStateAwareChannelHandler.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e) |
void |
IdleStateAwareChannelUpstreamHandler.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractTrafficShapingHandler.handleDownstream(ChannelHandlerContext ctx,
ChannelEvent e) |
Copyright © 2008-2013 The Netty Project. All Rights Reserved.