| 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.group |
A channel registry which helps a user maintain the list of open
Channels and perform bulk operations on them. |
| org.jboss.netty.channel.local |
A virtual transport that enables the communication between the two
parties in the same virtual machine.
|
| org.jboss.netty.channel.socket |
Abstract TCP and UDP socket interfaces which extend the core channel API.
|
| 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.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.factorial | |
| org.jboss.netty.example.http.tunnel | |
| org.jboss.netty.example.http.upload | |
| org.jboss.netty.example.localtime | |
| org.jboss.netty.example.portunification | |
| org.jboss.netty.example.proxy | |
| 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.ssl |
SSL ·
TLS implementation based on
SSLEngine |
| org.jboss.netty.handler.timeout |
Adds support for read and write timeout and idle connection notification
using a
Timer. |
| Modifier and Type | Method and Description |
|---|---|
Channel |
ConnectionlessBootstrap.bind()
Creates a new channel which is bound to the local address which was
specified in the current
"localAddress" option. |
Channel |
ServerBootstrap.bind()
Creates a new channel which is bound to the local address which was
specified in the current
"localAddress" option. |
Channel |
ConnectionlessBootstrap.bind(java.net.SocketAddress localAddress)
Creates a new channel which is bound to the specified local address.
|
Channel |
ServerBootstrap.bind(java.net.SocketAddress localAddress)
Creates a new channel which is bound to the specified local address.
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
ServerChannel
|
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractChannel
A skeletal
Channel implementation. |
class |
AbstractServerChannel
A skeletal server-side
Channel implementation. |
| Modifier and Type | Field and Description |
|---|---|
private Channel |
CompleteChannelFuture.channel |
private Channel |
DefaultChannelFuture.channel |
private Channel |
DefaultChannelPipeline.channel |
private Channel |
DefaultExceptionEvent.channel |
private Channel |
DefaultWriteCompletionEvent.channel |
private Channel |
DownstreamChannelStateEvent.channel |
private Channel |
DownstreamMessageEvent.channel |
private Channel |
UpstreamChannelStateEvent.channel |
private Channel |
UpstreamMessageEvent.channel |
private Channel |
DefaultChildChannelStateEvent.childChannel |
private Channel |
AbstractChannel.parent |
private Channel |
DefaultChildChannelStateEvent.parentChannel |
| Modifier and Type | Field and Description |
|---|---|
(package private) static java.util.concurrent.ConcurrentMap<java.lang.Integer,Channel> |
AbstractChannel.allChannels |
private java.util.concurrent.ConcurrentMap<Channel,T> |
ChannelLocal.map |
| Modifier and Type | Method and Description |
|---|---|
Channel |
ChannelEvent.getChannel()
Returns the
Channel which is associated with this event. |
Channel |
ChannelFuture.getChannel()
Returns a channel where the I/O operation associated with this
future takes place.
|
Channel |
ChannelHandlerContext.getChannel()
Returns the
Channel that the ChannelPipeline belongs to. |
Channel |
ChannelPipeline.getChannel()
Returns the
Channel that this pipeline is attached to. |
Channel |
ChildChannelStateEvent.getChannel()
Returns the parent
Channel which is associated
with this event. |
Channel |
CompleteChannelFuture.getChannel() |
Channel |
DefaultChannelFuture.getChannel() |
Channel |
DefaultChannelPipeline.getChannel() |
Channel |
DefaultChannelPipeline.DefaultChannelHandlerContext.getChannel() |
Channel |
DefaultChildChannelStateEvent.getChannel() |
Channel |
DefaultExceptionEvent.getChannel() |
Channel |
DefaultWriteCompletionEvent.getChannel() |
Channel |
DownstreamChannelStateEvent.getChannel() |
Channel |
DownstreamMessageEvent.getChannel() |
Channel |
UpstreamChannelStateEvent.getChannel() |
Channel |
UpstreamMessageEvent.getChannel() |
Channel |
ChildChannelStateEvent.getChildChannel()
Returns the child
Channel whose state has been changed. |
Channel |
DefaultChildChannelStateEvent.getChildChannel() |
Channel |
AbstractChannel.getParent() |
Channel |
Channel.getParent()
Returns the parent of this channel.
|
Channel |
ChannelFactory.newChannel(ChannelPipeline pipeline)
|
| Modifier and Type | Method and Description |
|---|---|
java.util.Iterator<java.util.Map.Entry<Channel,T>> |
ChannelLocal.iterator()
Returns a read-only
Iterator that holds all Map.Entry's of this ChannelLocal |
| Modifier and Type | Method and Description |
|---|---|
private static java.lang.Integer |
AbstractChannel.allocateId(Channel channel) |
void |
ChannelPipeline.attach(Channel channel,
ChannelSink sink)
Attaches this pipeline to the specified
Channel and
ChannelSink. |
void |
DefaultChannelPipeline.attach(Channel channel,
ChannelSink sink) |
static ChannelFuture |
Channels.bind(Channel channel,
java.net.SocketAddress localAddress)
Sends a
"bind" request to the last
ChannelDownstreamHandler in the ChannelPipeline of
the specified Channel. |
static ChannelFuture |
Channels.close(Channel channel)
Sends a
"close" request to the last
ChannelDownstreamHandler in the ChannelPipeline of
the specified Channel. |
int |
AbstractChannel.compareTo(Channel o)
Compares the ID of the two channels.
|
static ChannelFuture |
Channels.connect(Channel channel,
java.net.SocketAddress remoteAddress)
Sends a
"connect" request to the last
ChannelDownstreamHandler in the ChannelPipeline of
the specified Channel. |
static ChannelFuture |
Channels.disconnect(Channel channel)
Sends a
"disconnect" request to the last
ChannelDownstreamHandler in the ChannelPipeline of
the specified Channel. |
static ChannelFuture |
Channels.failedFuture(Channel channel,
java.lang.Throwable cause)
Creates a new
ChannelFuture which has failed already for the
specified Channel. |
static void |
Channels.fireChannelBound(Channel channel,
java.net.SocketAddress localAddress)
Sends a
"channelBound" event to the first
ChannelUpstreamHandler in the ChannelPipeline of
the specified Channel. |
static void |
Channels.fireChannelClosed(Channel channel)
Sends a
"channelClosed" event to the first
ChannelUpstreamHandler in the ChannelPipeline of
the specified Channel. |
static ChannelFuture |
Channels.fireChannelClosedLater(Channel channel)
Sends a
"channelClosed" event to the first
ChannelUpstreamHandler in the ChannelPipeline of
the specified Channel once the io-thread runs again. |
static void |
Channels.fireChannelConnected(Channel channel,
java.net.SocketAddress remoteAddress)
Sends a
"channelConnected" event to the first
ChannelUpstreamHandler in the ChannelPipeline of
the specified Channel. |
static void |
Channels.fireChannelDisconnected(Channel channel)
Sends a
"channelDisconnected" event to the first
ChannelUpstreamHandler in the ChannelPipeline of
the specified Channel. |
static ChannelFuture |
Channels.fireChannelDisconnectedLater(Channel channel)
Sends a
"channelDisconnected" event to the first
ChannelUpstreamHandler in the ChannelPipeline of
the specified Channel once the io-thread runs again. |
static void |
Channels.fireChannelInterestChanged(Channel channel)
Sends a
"channelInterestChanged" event to the first
ChannelUpstreamHandler in the ChannelPipeline of
the specified Channel. |
static ChannelFuture |
Channels.fireChannelInterestChangedLater(Channel channel)
Sends a
"channelInterestChanged" event to the first
ChannelUpstreamHandler in the ChannelPipeline of
the specified Channel once the io-thread runs again. |
static void |
Channels.fireChannelOpen(Channel channel)
Sends a
"channelOpen" event to the first
ChannelUpstreamHandler in the ChannelPipeline of
the specified Channel. |
static void |
Channels.fireChannelUnbound(Channel channel)
Sends a
"channelUnbound" event to the first
ChannelUpstreamHandler in the ChannelPipeline of
the specified Channel. |
static ChannelFuture |
Channels.fireChannelUnboundLater(Channel channel)
Sends a
"channelUnbound" event to the first
ChannelUpstreamHandler in the ChannelPipeline of
the specified Channel once the io-thread runs again. |
private static void |
Channels.fireChildChannelStateChanged(Channel channel,
Channel childChannel) |
static void |
Channels.fireExceptionCaught(Channel channel,
java.lang.Throwable cause)
Sends a
"exceptionCaught" event to the first
ChannelUpstreamHandler in the ChannelPipeline of
the specified Channel. |
static ChannelFuture |
Channels.fireExceptionCaughtLater(Channel channel,
java.lang.Throwable cause)
Sends a
"exceptionCaught" event to the first
ChannelUpstreamHandler in the ChannelPipeline of
the specified Channel once the io-thread runs again. |
static void |
Channels.fireMessageReceived(Channel channel,
java.lang.Object message)
Sends a
"messageReceived" event to the first
ChannelUpstreamHandler in the ChannelPipeline of
the specified Channel. |
static void |
Channels.fireMessageReceived(Channel channel,
java.lang.Object message,
java.net.SocketAddress remoteAddress)
Sends a
"messageReceived" event to the first
ChannelUpstreamHandler in the ChannelPipeline of
the specified Channel belongs. |
static void |
Channels.fireWriteComplete(Channel channel,
long amount)
Sends a
"writeComplete" event to the first
ChannelUpstreamHandler in the ChannelPipeline of
the specified Channel. |
static ChannelFuture |
Channels.fireWriteCompleteLater(Channel channel,
long amount)
Sends a
"writeComplete" event to the first
ChannelUpstreamHandler in the ChannelPipeline of
the specified Channel in the next io-thread. |
static ChannelFuture |
Channels.future(Channel channel)
Creates a new non-cancellable
ChannelFuture for the specified
Channel. |
static ChannelFuture |
Channels.future(Channel channel,
boolean cancellable)
Creates a new
ChannelFuture for the specified Channel. |
T |
ChannelLocal.get(Channel channel)
Returns the value of this variable.
|
protected T |
ChannelLocal.initialValue(Channel channel)
Returns the initial value of the variable.
|
T |
ChannelLocal.remove(Channel channel)
Removes the variable and returns the removed value.
|
T |
ChannelLocal.set(Channel channel,
T value)
Sets the value of this variable.
|
T |
ChannelLocal.setIfAbsent(Channel channel,
T value)
Sets the value of this variable only when no value was set.
|
static ChannelFuture |
Channels.setInterestOps(Channel channel,
int interestOps)
Sends a
"setInterestOps" request to the last
ChannelDownstreamHandler in the ChannelPipeline of
the specified Channel. |
static ChannelFuture |
Channels.succeededFuture(Channel channel)
Creates a new
ChannelFuture which is already succeeded for the
specified Channel. |
static ChannelFuture |
Channels.unbind(Channel channel)
Sends a
"unbind" request to the last
ChannelDownstreamHandler in the ChannelPipeline of
the specified Channel. |
static ChannelFuture |
Channels.write(Channel channel,
java.lang.Object message)
Sends a
"write" request to the last
ChannelDownstreamHandler in the ChannelPipeline of
the specified Channel. |
static ChannelFuture |
Channels.write(Channel channel,
java.lang.Object message,
java.net.SocketAddress remoteAddress)
Sends a
"write" request to the last
ChannelDownstreamHandler in the ChannelPipeline of
the specified Channel. |
| Constructor and Description |
|---|
AbstractChannel(Channel parent,
ChannelFactory factory,
ChannelPipeline pipeline,
ChannelSink sink)
Creates a new instance.
|
AbstractChannel(java.lang.Integer id,
Channel parent,
ChannelFactory factory,
ChannelPipeline pipeline,
ChannelSink sink)
(Internal use only) Creates a new temporary instance with the specified
ID.
|
CompleteChannelFuture(Channel channel)
Creates a new instance.
|
DefaultChannelFuture(Channel channel,
boolean cancellable)
Creates a new instance.
|
DefaultChildChannelStateEvent(Channel parentChannel,
Channel childChannel)
Creates a new instance.
|
DefaultExceptionEvent(Channel channel,
java.lang.Throwable cause)
Creates a new instance.
|
DefaultWriteCompletionEvent(Channel channel,
long writtenAmount)
Creates a new instance.
|
DownstreamChannelStateEvent(Channel channel,
ChannelFuture future,
ChannelState state,
java.lang.Object value)
Creates a new instance.
|
DownstreamMessageEvent(Channel channel,
ChannelFuture future,
java.lang.Object message,
java.net.SocketAddress remoteAddress)
Creates a new instance.
|
FailedChannelFuture(Channel channel,
java.lang.Throwable cause)
Creates a new instance.
|
SucceededChannelFuture(Channel channel)
Creates a new instance.
|
UpstreamChannelStateEvent(Channel channel,
ChannelState state,
java.lang.Object value)
Creates a new instance.
|
UpstreamMessageEvent(Channel channel,
java.lang.Object message,
java.net.SocketAddress remoteAddress)
Creates a new instance.
|
| Modifier and Type | Field and Description |
|---|---|
private java.util.concurrent.ConcurrentMap<java.lang.Integer,Channel> |
DefaultChannelGroup.nonServerChannels |
private java.util.concurrent.ConcurrentMap<java.lang.Integer,Channel> |
DefaultChannelGroup.serverChannels |
| Modifier and Type | Method and Description |
|---|---|
Channel |
ChannelGroup.find(java.lang.Integer id)
Returns the
Channel whose ID matches the specified integer. |
Channel |
DefaultChannelGroup.find(java.lang.Integer id) |
| Modifier and Type | Method and Description |
|---|---|
java.util.Iterator<Channel> |
DefaultChannelGroup.iterator() |
| Modifier and Type | Method and Description |
|---|---|
boolean |
DefaultChannelGroup.add(Channel channel) |
ChannelFuture |
ChannelGroupFuture.find(Channel channel)
Returns the
ChannelFuture of the individual I/O operation which
is associated with the specified Channel. |
ChannelFuture |
DefaultChannelGroupFuture.find(Channel channel) |
| Modifier and Type | Interface and Description |
|---|---|
interface |
LocalChannel
A
Channel for the local transport. |
interface |
LocalServerChannel
A
ServerChannel for the local transport. |
| Modifier and Type | Class and Description |
|---|---|
(package private) class |
DefaultLocalChannel |
(package private) class |
DefaultLocalServerChannel |
| Modifier and Type | Field and Description |
|---|---|
private static java.util.concurrent.ConcurrentMap<LocalAddress,Channel> |
LocalChannelRegistry.map |
| Modifier and Type | Method and Description |
|---|---|
(package private) static Channel |
LocalChannelRegistry.getChannel(LocalAddress address) |
| Modifier and Type | Method and Description |
|---|---|
(package private) static boolean |
LocalChannelRegistry.register(LocalAddress address,
Channel channel) |
| Modifier and Type | Interface and Description |
|---|---|
interface |
DatagramChannel
A UDP/IP
Channel which is created by DatagramChannelFactory. |
interface |
ServerSocketChannel
A TCP/IP
ServerChannel which accepts incoming TCP/IP connections. |
interface |
SocketChannel
A TCP/IP socket
Channel which was either accepted by
ServerSocketChannel or created by ClientSocketChannelFactory. |
| Constructor and Description |
|---|
ChannelRunnableWrapper(Channel channel,
java.lang.Runnable task) |
| Modifier and Type | Class and Description |
|---|---|
(package private) class |
HttpTunnelingClientSocketChannel |
| Modifier and Type | Class and Description |
|---|---|
(package private) class |
AbstractNioChannel<C extends java.nio.channels.SelectableChannel & java.nio.channels.WritableByteChannel> |
(package private) class |
NioAcceptedSocketChannel |
(package private) class |
NioClientSocketChannel |
class |
NioDatagramChannel
Provides an NIO based
DatagramChannel. |
(package private) class |
NioServerSocketChannel |
class |
NioSocketChannel |
| Modifier and Type | Method and Description |
|---|---|
protected abstract java.lang.Runnable |
AbstractNioSelector.createRegisterTask(Channel channel,
ChannelFuture future) |
protected java.lang.Runnable |
NioClientBoss.createRegisterTask(Channel channel,
ChannelFuture future) |
protected java.lang.Runnable |
NioDatagramWorker.createRegisterTask(Channel channel,
ChannelFuture future) |
protected java.lang.Runnable |
NioServerBoss.createRegisterTask(Channel channel,
ChannelFuture future) |
protected java.lang.Runnable |
NioWorker.createRegisterTask(Channel channel,
ChannelFuture future) |
void |
AbstractNioSelector.register(Channel channel,
ChannelFuture future) |
void |
NioSelector.register(Channel channel,
ChannelFuture future) |
| Constructor and Description |
|---|
AbstractNioChannel(Channel parent,
ChannelFactory factory,
ChannelPipeline pipeline,
ChannelSink sink,
AbstractNioWorker worker,
C ch) |
AbstractNioChannel(java.lang.Integer id,
Channel parent,
ChannelFactory factory,
ChannelPipeline pipeline,
ChannelSink sink,
AbstractNioWorker worker,
C ch) |
NioAcceptedSocketChannel(ChannelFactory factory,
ChannelPipeline pipeline,
Channel parent,
ChannelSink sink,
java.nio.channels.SocketChannel socket,
NioWorker worker,
java.lang.Thread bossThread) |
NioSocketChannel(Channel parent,
ChannelFactory factory,
ChannelPipeline pipeline,
ChannelSink sink,
java.nio.channels.SocketChannel socket,
NioWorker worker) |
| Modifier and Type | Class and Description |
|---|---|
(package private) class |
AbstractOioChannel |
(package private) class |
OioAcceptedSocketChannel |
(package private) class |
OioClientSocketChannel |
(package private) class |
OioDatagramChannel |
(package private) class |
OioServerSocketChannel |
(package private) class |
OioSocketChannel |
| Constructor and Description |
|---|
AbstractOioChannel(Channel parent,
ChannelFactory factory,
ChannelPipeline pipeline,
ChannelSink sink) |
OioAcceptedSocketChannel(Channel parent,
ChannelFactory factory,
ChannelPipeline pipeline,
ChannelSink sink,
java.net.Socket socket) |
OioSocketChannel(Channel parent,
ChannelFactory factory,
ChannelPipeline pipeline,
ChannelSink sink,
java.net.Socket socket) |
| Modifier and Type | Method and Description |
|---|---|
protected java.lang.Object |
BigIntegerDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer) |
protected java.lang.Object |
NumberEncoder.encode(ChannelHandlerContext ctx,
Channel channel,
java.lang.Object msg) |
| Modifier and Type | Field and Description |
|---|---|
private Channel |
LocalEchoServerRegistration.serverChannel |
| Modifier and Type | Method and Description |
|---|---|
private void |
HttpUploadServerHandler.readHttpDataAllReceive(Channel channel)
Example of reading all InterfaceHttpData from finished transfer
|
private void |
HttpUploadServerHandler.writeResponse(Channel channel) |
| Modifier and Type | Field and Description |
|---|---|
private Channel |
LocalTimeClientHandler.channel |
| Modifier and Type | Method and Description |
|---|---|
protected java.lang.Object |
PortUnificationServerHandler.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer) |
| Modifier and Type | Field and Description |
|---|---|
private Channel |
HexDumpProxyInboundHandler.OutboundHandler.inboundChannel |
private Channel |
HexDumpProxyInboundHandler.outboundChannel |
| Modifier and Type | Method and Description |
|---|---|
(package private) static void |
HexDumpProxyInboundHandler.closeOnFlush(Channel ch)
Closes the specified channel after all queued write requests are flushed.
|
| Constructor and Description |
|---|
OutboundHandler(Channel inboundChannel) |
| 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 | Method and Description |
|---|---|
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) |
| Modifier and Type | Class and Description |
|---|---|
(package private) class |
EmbeddedChannel
TODO Make EmbeddedChannel implement ChannelConfig and ChannelSink to reduce overhead.
|
| Modifier and Type | Field and Description |
|---|---|
private Channel |
AbstractCodecEmbedder.channel |
| Modifier and Type | Method and Description |
|---|---|
protected Channel |
AbstractCodecEmbedder.getChannel()
Returns the virtual
Channel which will be used as a mock
during encoding and decoding. |
Channel |
EmbeddedChannelFactory.newChannel(ChannelPipeline pipeline) |
| Modifier and Type | Method and Description |
|---|---|
private void |
FrameDecoder.callDecode(ChannelHandlerContext context,
Channel channel,
ChannelBuffer cumulation,
java.net.SocketAddress remoteAddress) |
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) |
| Modifier and Type | Method and Description |
|---|---|
protected java.lang.Object |
HttpClientCodec.Decoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer,
HttpMessageDecoder.State state) |
protected java.lang.Object |
HttpMessageDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer,
HttpMessageDecoder.State state) |
protected java.lang.Object |
HttpClientCodec.Encoder.encode(ChannelHandlerContext ctx,
Channel channel,
java.lang.Object msg) |
protected java.lang.Object |
HttpMessageEncoder.encode(ChannelHandlerContext ctx,
Channel channel,
java.lang.Object msg) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
WebSocket08FrameDecoder.checkCloseFrameBody(Channel channel,
ChannelBuffer buffer) |
private void |
WebSocket08FrameDecoder.checkUTF8String(Channel channel,
byte[] bytes) |
abstract ChannelFuture |
WebSocketServerHandshaker.close(Channel channel,
CloseWebSocketFrame frame)
Performs the closing handshake
|
ChannelFuture |
WebSocketServerHandshaker00.close(Channel channel,
CloseWebSocketFrame frame)
Echo back the closing frame
|
ChannelFuture |
WebSocketServerHandshaker07.close(Channel channel,
CloseWebSocketFrame frame)
Echo back the closing frame and close the connection
|
ChannelFuture |
WebSocketServerHandshaker08.close(Channel channel,
CloseWebSocketFrame frame)
Echo back the closing frame and close the connection
|
ChannelFuture |
WebSocketServerHandshaker13.close(Channel channel,
CloseWebSocketFrame frame)
Echo back the closing frame and close the connection
|
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) |
abstract void |
WebSocketClientHandshaker.finishHandshake(Channel channel,
HttpResponse response)
Validates and finishes the opening handshake initiated by
WebSocketClientHandshaker.handshake(org.jboss.netty.channel.Channel)}. |
void |
WebSocketClientHandshaker00.finishHandshake(Channel channel,
HttpResponse response)
Process server response:
|
void |
WebSocketClientHandshaker07.finishHandshake(Channel channel,
HttpResponse response)
Process server response:
|
void |
WebSocketClientHandshaker08.finishHandshake(Channel channel,
HttpResponse response)
Process server response:
|
void |
WebSocketClientHandshaker13.finishHandshake(Channel channel,
HttpResponse response)
Process server response:
|
abstract ChannelFuture |
WebSocketClientHandshaker.handshake(Channel channel)
Begins the opening handshake
|
ChannelFuture |
WebSocketClientHandshaker00.handshake(Channel channel)
Sends the opening request to the server:
|
ChannelFuture |
WebSocketClientHandshaker07.handshake(Channel channel)
/**
|
ChannelFuture |
WebSocketClientHandshaker08.handshake(Channel channel)
/**
|
ChannelFuture |
WebSocketClientHandshaker13.handshake(Channel channel)
/**
|
abstract ChannelFuture |
WebSocketServerHandshaker.handshake(Channel channel,
HttpRequest req)
Performs the opening handshake
|
ChannelFuture |
WebSocketServerHandshaker00.handshake(Channel channel,
HttpRequest req)
Handle the web socket handshake for the web socket specification HyBi version 0 and lower.
|
ChannelFuture |
WebSocketServerHandshaker07.handshake(Channel channel,
HttpRequest req)
Handle the web socket handshake for the web socket specification HyBi version 7.
|
ChannelFuture |
WebSocketServerHandshaker08.handshake(Channel channel,
HttpRequest req)
Handle the web socket handshake for the web socket specification HyBi version 8 to 10.
|
ChannelFuture |
WebSocketServerHandshaker13.handshake(Channel channel,
HttpRequest req)
Handle the web socket handshake for the web socket specification HyBi
versions 13-17.
|
private void |
WebSocket08FrameDecoder.protocolViolation(Channel channel,
CorruptedFrameException ex) |
private void |
WebSocket08FrameDecoder.protocolViolation(Channel channel,
java.lang.String reason) |
(package private) static void |
WebSocketClientHandshaker.replaceDecoder(Channel channel,
ChannelHandler wsDecoder)
Replace the HTTP decoder with a new Web Socket decoder.
|
ChannelFuture |
WebSocketServerHandshakerFactory.sendUnsupportedWebSocketVersionResponse(Channel channel)
Return that we need cannot not support the web socket version
|
protected ChannelFuture |
WebSocketServerHandshaker.writeHandshakeResponse(Channel channel,
HttpResponse res,
ChannelHandler encoder,
ChannelHandler decoder)
Upgrades the connection and send the handshake response.
|
| 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) |
| 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 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.
|
| 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 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.
|
| 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 |
|---|---|
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 | Method and Description |
|---|---|
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) |
private void |
SpdySessionHandler.issueSessionError(ChannelHandlerContext ctx,
Channel channel,
java.net.SocketAddress remoteAddress,
SpdySessionStatus status) |
private ChannelFuture |
SpdySessionHandler.sendGoAwayFrame(ChannelHandlerContext ctx,
Channel channel,
java.net.SocketAddress remoteAddress,
SpdySessionStatus status) |
| 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 |
|---|---|
private java.util.concurrent.ConcurrentMap<Channel,java.util.concurrent.atomic.AtomicLong> |
MemoryAwareThreadPoolExecutor.channelCounters |
| Modifier and Type | Method and Description |
|---|---|
private java.util.concurrent.atomic.AtomicLong |
MemoryAwareThreadPoolExecutor.getChannelCounter(Channel channel) |
| Modifier and Type | Method and Description |
|---|---|
Channel |
SslHandler.SSLEngineInboundCloseFuture.getChannel() |
| Modifier and Type | Method and Description |
|---|---|
protected java.lang.Object |
SslHandler.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer in) |
private void |
SslHandler.setHandshakeFailure(Channel channel,
javax.net.ssl.SSLException cause) |
private void |
SslHandler.setHandshakeSuccess(Channel channel) |
private boolean |
SslHandler.setHandshakeSuccessIfStillHandshaking(Channel channel)
Works around some Android
SSLEngine implementations that skip SSLEngineResult.HandshakeStatus.FINISHED and
go straight into SSLEngineResult.HandshakeStatus.NOT_HANDSHAKING when handshake is finished. |
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) |
| Modifier and Type | Field and Description |
|---|---|
private Channel |
DefaultIdleStateEvent.channel |
| Modifier and Type | Method and Description |
|---|---|
Channel |
DefaultIdleStateEvent.getChannel() |
| Constructor and Description |
|---|
DefaultIdleStateEvent(Channel channel,
IdleState state,
long lastActivityTimeMillis)
Creates a new instance.
|