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.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.websocket | |
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.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 |
DefaultChannelPipeline.getContext(ChannelHandler handler) |
ChannelHandlerContext |
ChannelPipeline.getContext(ChannelHandler handler)
Returns the context object of the specified
ChannelHandler in
this pipeline. |
ChannelHandlerContext |
StaticChannelPipeline.getContext(ChannelHandler handler)
Deprecated.
|
ChannelHandlerContext |
DefaultChannelPipeline.getContext(Class<? extends ChannelHandler> handlerType) |
ChannelHandlerContext |
ChannelPipeline.getContext(Class<? extends ChannelHandler> handlerType)
Returns the context object of the
ChannelHandler of the
specified type in this pipeline. |
ChannelHandlerContext |
StaticChannelPipeline.getContext(Class<? extends ChannelHandler> handlerType)
Deprecated.
|
ChannelHandlerContext |
DefaultChannelPipeline.getContext(String name) |
ChannelHandlerContext |
ChannelPipeline.getContext(String name)
Returns the context object of the
ChannelHandler with the
specified name in this pipeline. |
ChannelHandlerContext |
StaticChannelPipeline.getContext(String name)
Deprecated.
|
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 |
SimpleChannelDownstreamHandler.handleDownstream(ChannelHandlerContext ctx,
ChannelEvent e)
Handles the specified downstream event.
|
void |
ChannelDownstreamHandler.handleDownstream(ChannelHandlerContext ctx,
ChannelEvent e)
Handles the specified downstream event.
|
void |
SimpleChannelHandler.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e)
Handles the specified upstream event.
|
void |
ChannelUpstreamHandler.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 |
---|---|
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 |
DelimiterBasedFrameDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer) |
protected Object |
FixedLengthFrameDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer) |
protected Object |
LengthFieldBasedFrameDecoder.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 |
---|---|
protected Object |
WebSocketFrameDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer,
VoidEnum state)
Deprecated.
|
protected Object |
WebSocketFrameEncoder.encode(ChannelHandlerContext ctx,
Channel channel,
Object msg)
Deprecated.
|
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 |
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 |
DefaultMarshallerProvider.getMarshaller(ChannelHandlerContext ctx) |
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.Unmarshaller |
DefaultUnmarshallerProvider.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) |
org.jboss.marshalling.Unmarshaller |
ContextBoundUnmarshallerProvider.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 |
ProtobufEncoder.encode(ChannelHandlerContext ctx,
Channel channel,
Object msg) |
protected Object |
ProtobufVarint32LengthFieldPrepender.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 |
CompatibleObjectDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer,
org.jboss.netty.handler.codec.serialization.CompatibleObjectDecoderState state)
Deprecated.
|
protected Object |
CompatibleObjectDecoder.decodeLast(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer,
org.jboss.netty.handler.codec.serialization.CompatibleObjectDecoderState state)
Deprecated.
|
protected Object |
CompatibleObjectEncoder.encode(ChannelHandlerContext context,
Channel channel,
Object msg) |
protected Object |
ObjectEncoder.encode(ChannelHandlerContext ctx,
Channel channel,
Object msg) |
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 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().
|
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.
|
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.
|
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) |
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 buffer) |
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 |
IdleStateAwareChannelUpstreamHandler.channelIdle(ChannelHandlerContext ctx,
IdleStateEvent e)
Invoked when a
Channel has been idle for a while. |
void |
IdleStateAwareChannelHandler.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 |
IdleStateAwareChannelUpstreamHandler.handleUpstream(ChannelHandlerContext ctx,
ChannelEvent e) |
void |
IdleStateAwareChannelHandler.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 |
ChannelTrafficShapingHandler.channelClosed(ChannelHandlerContext ctx,
ChannelStateEvent e) |
void |
ChannelTrafficShapingHandler.channelConnected(ChannelHandlerContext ctx,
ChannelStateEvent e) |
void |
AbstractTrafficShapingHandler.handleDownstream(ChannelHandlerContext ctx,
ChannelEvent e) |
void |
AbstractTrafficShapingHandler.messageReceived(ChannelHandlerContext ctx,
MessageEvent e) |
void |
AbstractTrafficShapingHandler.writeRequested(ChannelHandlerContext ctx,
MessageEvent e) |
Copyright © 2008-2013 The Netty Project. All Rights Reserved.