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.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.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.replay |
Specialized variation of
FrameDecoder
which enables implementation of a non-blocking decoder in the blocking I/O
paradigm. |
org.jboss.netty.handler.codec.spdy |
Encoder, decoder, session handler and their related message types for the SPDY protocol.
|
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.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 | Class and Description |
---|---|
class |
DownstreamMessageEvent
The default downstream
MessageEvent implementation. |
class |
UpstreamMessageEvent
The default upstream
MessageEvent implementation. |
Modifier and Type | Method and Description |
---|---|
void |
SimpleChannelUpstreamHandler.messageReceived(ChannelHandlerContext ctx,
MessageEvent e)
Invoked when a message object (e.g:
ChannelBuffer ) was received
from a remote peer. |
void |
SimpleChannelHandler.messageReceived(ChannelHandlerContext ctx,
MessageEvent e)
Invoked when a message object (e.g:
ChannelBuffer ) was received
from a remote peer. |
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 |
FrameDecoder.messageReceived(ChannelHandlerContext ctx,
MessageEvent e) |
Modifier and Type | Method and Description |
---|---|
void |
HttpContentEncoder.messageReceived(ChannelHandlerContext ctx,
MessageEvent e) |
void |
HttpContentDecoder.messageReceived(ChannelHandlerContext ctx,
MessageEvent e) |
void |
HttpChunkAggregator.messageReceived(ChannelHandlerContext ctx,
MessageEvent e) |
void |
HttpContentEncoder.writeRequested(ChannelHandlerContext ctx,
MessageEvent e) |
Modifier and Type | Method and Description |
---|---|
void |
WebSocketServerProtocolHandshakeHandler.messageReceived(ChannelHandlerContext ctx,
MessageEvent e) |
void |
WebSocketServerProtocolHandler.messageReceived(ChannelHandlerContext ctx,
MessageEvent e) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
OneToOneStrictEncoder.doEncode(ChannelHandlerContext ctx,
MessageEvent e) |
protected boolean |
OneToOneEncoder.doEncode(ChannelHandlerContext ctx,
MessageEvent e) |
Modifier and Type | Method and Description |
---|---|
void |
ReplayingDecoder.messageReceived(ChannelHandlerContext ctx,
MessageEvent e) |
Modifier and Type | Method and Description |
---|---|
void |
SpdySessionHandler.messageReceived(ChannelHandlerContext ctx,
MessageEvent e) |
void |
SpdyHttpResponseStreamIdHandler.messageReceived(ChannelHandlerContext ctx,
MessageEvent e) |
void |
SpdyHttpResponseStreamIdHandler.writeRequested(ChannelHandlerContext ctx,
MessageEvent e) |
Modifier and Type | Method and Description |
---|---|
protected Queue<MessageEvent> |
BufferedWriteHandler.getQueue()
Returns the queue which stores the write requests.
|
Modifier and Type | Method and Description |
---|---|
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() . |
Constructor and Description |
---|
BufferedWriteHandler(Queue<MessageEvent> queue)
Creates a new instance with the specified thread-safe unbounded
Queue and without buffer consolidation. |
BufferedWriteHandler(Queue<MessageEvent> queue,
boolean consolidateOnFlush)
Creates a new instance with the specified thread-safe unbounded
Queue . |
Modifier and Type | Method and Description |
---|---|
protected long |
WriteTimeoutHandler.getTimeoutMillis(MessageEvent e)
Returns the write timeout of the specified event.
|
void |
ReadTimeoutHandler.messageReceived(ChannelHandlerContext ctx,
MessageEvent e) |
void |
IdleStateHandler.messageReceived(ChannelHandlerContext ctx,
MessageEvent e) |
void |
WriteTimeoutHandler.writeRequested(ChannelHandlerContext ctx,
MessageEvent e) |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractTrafficShapingHandler.internalSubmitWrite(ChannelHandlerContext ctx,
MessageEvent evt) |
void |
AbstractTrafficShapingHandler.messageReceived(ChannelHandlerContext ctx,
MessageEvent evt) |
protected void |
GlobalTrafficShapingHandler.submitWrite(ChannelHandlerContext ctx,
MessageEvent evt,
long delay) |
protected void |
ChannelTrafficShapingHandler.submitWrite(ChannelHandlerContext ctx,
MessageEvent evt,
long delay) |
protected abstract void |
AbstractTrafficShapingHandler.submitWrite(ChannelHandlerContext ctx,
MessageEvent evt,
long delay) |
void |
AbstractTrafficShapingHandler.writeRequested(ChannelHandlerContext ctx,
MessageEvent evt) |
Copyright © 2008-2015 The Netty Project. All Rights Reserved.