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
Channel s 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.nio |
NIO-based socket channel
API implementation - recommended for a large number of connections (>= 1000).
|
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.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.ssl | |
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 |
ServerBootstrap.bind()
Creates a new channel which is bound to the local address which was
specified in the current
"localAddress" option. |
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(SocketAddress localAddress)
Creates a new channel which is bound to the specified local address.
|
Channel |
ConnectionlessBootstrap.bind(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 | Method and Description |
---|---|
Channel |
UpstreamMessageEvent.getChannel() |
Channel |
UpstreamChannelStateEvent.getChannel() |
Channel |
StaticChannelPipeline.getChannel()
Deprecated.
|
Channel |
DownstreamMessageEvent.getChannel() |
Channel |
DownstreamChannelStateEvent.getChannel() |
Channel |
DefaultWriteCompletionEvent.getChannel() |
Channel |
DefaultExceptionEvent.getChannel() |
Channel |
DefaultChildChannelStateEvent.getChannel() |
Channel |
DefaultChannelPipeline.getChannel() |
Channel |
DefaultChannelFuture.getChannel() |
Channel |
CompleteChannelFuture.getChannel() |
Channel |
ChildChannelStateEvent.getChannel()
Returns the parent
Channel which is associated
with this event. |
Channel |
ChannelPipeline.getChannel()
Returns the
Channel that this pipeline is attached to. |
Channel |
ChannelHandlerContext.getChannel()
Returns the
Channel that the ChannelPipeline belongs to. |
Channel |
ChannelFuture.getChannel()
Returns a channel where the I/O operation associated with this
future takes place.
|
Channel |
ChannelEvent.getChannel()
Returns the
Channel which is associated with this event. |
Channel |
DefaultChildChannelStateEvent.getChildChannel() |
Channel |
ChildChannelStateEvent.getChildChannel()
Returns the child
Channel whose state has been changed. |
Channel |
Channel.getParent()
Returns the parent of this channel.
|
Channel |
AbstractChannel.getParent() |
Channel |
ChannelFactory.newChannel(ChannelPipeline pipeline)
|
Modifier and Type | Method and Description |
---|---|
Iterator<Map.Entry<Channel,T>> |
ChannelLocal.iterator()
|
Modifier and Type | Method and Description |
---|---|
void |
StaticChannelPipeline.attach(Channel channel,
ChannelSink sink)
Deprecated.
|
void |
DefaultChannelPipeline.attach(Channel channel,
ChannelSink sink) |
void |
ChannelPipeline.attach(Channel channel,
ChannelSink sink)
Attaches this pipeline to the specified
Channel and
ChannelSink . |
static ChannelFuture |
Channels.bind(Channel channel,
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,
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,
Throwable cause)
Creates a new
ChannelFuture which has failed already for the
specified Channel . |
static void |
Channels.fireChannelBound(Channel channel,
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,
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. |
static void |
Channels.fireExceptionCaught(Channel channel,
Throwable cause)
Sends a
"exceptionCaught" event to the first
ChannelUpstreamHandler in the ChannelPipeline of
the specified Channel . |
static ChannelFuture |
Channels.fireExceptionCaughtLater(Channel channel,
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,
Object message)
Sends a
"messageReceived" event to the first
ChannelUpstreamHandler in the ChannelPipeline of
the specified Channel . |
static void |
Channels.fireMessageReceived(Channel channel,
Object message,
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,
Object message)
Sends a
"write" request to the last
ChannelDownstreamHandler in the ChannelPipeline of
the specified Channel . |
static ChannelFuture |
Channels.write(Channel channel,
Object message,
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(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,
Throwable cause)
Creates a new instance.
|
DefaultWriteCompletionEvent(Channel channel,
long writtenAmount)
Creates a new instance.
|
DownstreamChannelStateEvent(Channel channel,
ChannelFuture future,
ChannelState state,
Object value)
Creates a new instance.
|
DownstreamMessageEvent(Channel channel,
ChannelFuture future,
Object message,
SocketAddress remoteAddress)
Creates a new instance.
|
FailedChannelFuture(Channel channel,
Throwable cause)
Creates a new instance.
|
SucceededChannelFuture(Channel channel)
Creates a new instance.
|
UpstreamChannelStateEvent(Channel channel,
ChannelState state,
Object value)
Creates a new instance.
|
UpstreamMessageEvent(Channel channel,
Object message,
SocketAddress remoteAddress)
Creates a new instance.
|
Modifier and Type | Method and Description |
---|---|
Channel |
DefaultChannelGroup.find(Integer id) |
Channel |
ChannelGroup.find(Integer id)
Returns the
Channel whose ID matches the specified integer. |
Modifier and Type | Method and Description |
---|---|
Iterator<Channel> |
DefaultChannelGroup.iterator() |
Modifier and Type | Method and Description |
---|---|
boolean |
DefaultChannelGroup.add(Channel channel) |
ChannelFuture |
DefaultChannelGroupFuture.find(Channel channel) |
ChannelFuture |
ChannelGroupFuture.find(Channel channel)
Returns the
ChannelFuture of the individual I/O operation which
is associated with the specified 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 | 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,
Runnable task) |
Modifier and Type | Class and Description |
---|---|
class |
NioDatagramChannel
Provides an NIO based
DatagramChannel . |
class |
NioSocketChannel |
Modifier and Type | Method and Description |
---|---|
protected Runnable |
NioWorker.createRegisterTask(Channel channel,
ChannelFuture future) |
protected Runnable |
NioServerBoss.createRegisterTask(Channel channel,
ChannelFuture future) |
protected Runnable |
NioDatagramWorker.createRegisterTask(Channel channel,
ChannelFuture future) |
protected Runnable |
NioClientBoss.createRegisterTask(Channel channel,
ChannelFuture future) |
void |
NioSelector.register(Channel channel,
ChannelFuture future) |
Constructor and Description |
---|
NioSocketChannel(Channel parent,
ChannelFactory factory,
ChannelPipeline pipeline,
ChannelSink sink,
SocketChannel socket,
NioWorker worker) |
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 |
---|---|
protected Object |
ZlibDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
Object msg) |
protected Object |
ZlibEncoder.encode(ChannelHandlerContext ctx,
Channel channel,
Object msg) |
protected Object |
JdkZlibEncoder.encode(ChannelHandlerContext ctx,
Channel channel,
Object msg) |
Modifier and Type | Method and Description |
---|---|
protected Object |
LineBasedFrameDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer) |
protected Object |
LengthFieldBasedFrameDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer) |
protected abstract Object |
FrameDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer)
Decodes the received packets so far into a frame.
|
protected Object |
FixedLengthFrameDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer) |
protected Object |
DelimiterBasedFrameDecoder.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) |
Modifier and Type | Method and Description |
---|---|
protected Object |
HttpMessageDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer,
HttpMessageDecoder.State state) |
protected Object |
HttpMessageEncoder.encode(ChannelHandlerContext ctx,
Channel channel,
Object msg) |
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 |
---|---|
protected void |
WebSocket08FrameDecoder.checkCloseFrameBody(Channel channel,
ChannelBuffer buffer) |
ChannelFuture |
WebSocketServerHandshaker13.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 |
WebSocketServerHandshaker07.close(Channel channel,
CloseWebSocketFrame frame)
Echo back the closing frame and close the connection
|
ChannelFuture |
WebSocketServerHandshaker00.close(Channel channel,
CloseWebSocketFrame frame)
Echo back the closing frame
|
abstract ChannelFuture |
WebSocketServerHandshaker.close(Channel channel,
CloseWebSocketFrame frame)
Performs the closing handshake
|
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 |
WebSocketFrameAggregator.decode(ChannelHandlerContext ctx,
Channel channel,
Object message) |
protected Object |
WebSocket08FrameEncoder.encode(ChannelHandlerContext ctx,
Channel channel,
Object msg) |
protected Object |
WebSocket00FrameEncoder.encode(ChannelHandlerContext ctx,
Channel channel,
Object msg) |
void |
WebSocketClientHandshaker13.finishHandshake(Channel channel,
HttpResponse response)
Process server response:
HTTP/1.1 101 Switching Protocols
Upgrade: websocket
Connection: Upgrade
Sec-WebSocket-Accept: s3pPLMBiTxaQ9kYGzzhZRbK+xOo=
Sec-WebSocket-Protocol: chat
|
void |
WebSocketClientHandshaker08.finishHandshake(Channel channel,
HttpResponse response)
Process server response:
HTTP/1.1 101 Switching Protocols
Upgrade: websocket
Connection: Upgrade
Sec-WebSocket-Accept: s3pPLMBiTxaQ9kYGzzhZRbK+xOo=
Sec-WebSocket-Protocol: chat
|
void |
WebSocketClientHandshaker07.finishHandshake(Channel channel,
HttpResponse response)
Process server response:
HTTP/1.1 101 Switching Protocols
Upgrade: websocket
Connection: Upgrade
Sec-WebSocket-Accept: s3pPLMBiTxaQ9kYGzzhZRbK+xOo=
Sec-WebSocket-Protocol: chat
|
void |
WebSocketClientHandshaker00.finishHandshake(Channel channel,
HttpResponse response)
Process server response:
HTTP/1.1 101 WebSocket Protocol Handshake
Upgrade: WebSocket
Connection: Upgrade
Sec-WebSocket-Origin: http://example.com
Sec-WebSocket-Location: ws://example.com/demo
Sec-WebSocket-Protocol: sample
8jKS'y:G*Co,Wxa-
|
abstract void |
WebSocketClientHandshaker.finishHandshake(Channel channel,
HttpResponse response)
Validates and finishes the opening handshake initiated by
WebSocketClientHandshaker.handshake(org.jboss.netty.channel.Channel) }. |
ChannelFuture |
WebSocketClientHandshaker13.handshake(Channel channel)
/**
Sends the opening request to the server:
GET /chat HTTP/1.1
Host: server.example.com
Upgrade: websocket
Connection: Upgrade
Sec-WebSocket-Key: dGhlIHNhbXBsZSBub25jZQ==
Sec-WebSocket-Origin: http://example.com
Sec-WebSocket-Protocol: chat, superchat
Sec-WebSocket-Version: 13
|
ChannelFuture |
WebSocketClientHandshaker08.handshake(Channel channel)
/**
Sends the opening request to the server:
GET /chat HTTP/1.1
Host: server.example.com
Upgrade: websocket
Connection: Upgrade
Sec-WebSocket-Key: dGhlIHNhbXBsZSBub25jZQ==
Sec-WebSocket-Origin: http://example.com
Sec-WebSocket-Protocol: chat, superchat
Sec-WebSocket-Version: 8
|
ChannelFuture |
WebSocketClientHandshaker07.handshake(Channel channel)
/**
Sends the opening request to the server:
GET /chat HTTP/1.1
Host: server.example.com
Upgrade: websocket
Connection: Upgrade
Sec-WebSocket-Key: dGhlIHNhbXBsZSBub25jZQ==
Sec-WebSocket-Origin: http://example.com
Sec-WebSocket-Protocol: chat, superchat
Sec-WebSocket-Version: 7
|
ChannelFuture |
WebSocketClientHandshaker00.handshake(Channel channel)
Sends the opening request to the server:
GET /demo HTTP/1.1
Upgrade: WebSocket
Connection: Upgrade
Host: example.com
Origin: http://example.com
Sec-WebSocket-Key1: 4 @1 46546xW%0l 1 5
Sec-WebSocket-Key2: 12998 5 Y3 1 .P00
^n:ds[4U
|
abstract ChannelFuture |
WebSocketClientHandshaker.handshake(Channel channel)
Begins the opening handshake
|
ChannelFuture |
WebSocketServerHandshaker13.handshake(Channel channel,
HttpRequest req)
Handle the web socket handshake for the web socket specification HyBi
versions 13-17.
|
ChannelFuture |
WebSocketServerHandshaker08.handshake(Channel channel,
HttpRequest req)
Handle the web socket handshake for the web socket specification HyBi version 8 to 10.
|
ChannelFuture |
WebSocketServerHandshaker07.handshake(Channel channel,
HttpRequest req)
Handle the web socket handshake for the web socket specification HyBi version 7.
|
ChannelFuture |
WebSocketServerHandshaker00.handshake(Channel channel,
HttpRequest req)
Handle the web socket handshake for the web socket specification HyBi version 0 and lower.
|
abstract ChannelFuture |
WebSocketServerHandshaker.handshake(Channel channel,
HttpRequest req)
Performs the opening handshake
|
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 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 |
MarshallingEncoder.encode(ChannelHandlerContext ctx,
Channel channel,
Object msg) |
protected Object |
CompatibleMarshallingEncoder.encode(ChannelHandlerContext ctx,
Channel channel,
Object msg) |
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 abstract Object |
OneToOneEncoder.encode(ChannelHandlerContext ctx,
Channel channel,
Object msg)
Transforms the specified message into another message and return the
transformed message.
|
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 |
ProtobufVarint32LengthFieldPrepender.encode(ChannelHandlerContext ctx,
Channel channel,
Object msg) |
protected Object |
ProtobufEncoder.encode(ChannelHandlerContext ctx,
Channel channel,
Object msg) |
Modifier and Type | Method and Description |
---|---|
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.
|
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 |
ObjectEncoder.encode(ChannelHandlerContext ctx,
Channel channel,
Object msg) |
protected Object |
CompatibleObjectEncoder.encode(ChannelHandlerContext context,
Channel channel,
Object msg) |
Modifier and Type | Method and Description |
---|---|
protected Object |
SocksAuthRequestDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer,
org.jboss.netty.handler.codec.socks.SocksAuthRequestDecoder.State state) |
protected Object |
SocksAuthResponseDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer,
SocksAuthResponseDecoder.State state) |
protected Object |
SocksCmdRequestDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer,
org.jboss.netty.handler.codec.socks.SocksCmdRequestDecoder.State state) |
protected Object |
SocksCmdResponseDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer,
SocksCmdResponseDecoder.State state) |
protected Object |
SocksInitRequestDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer,
org.jboss.netty.handler.codec.socks.SocksInitRequestDecoder.State state) |
protected Object |
SocksInitResponseDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer,
SocksInitResponseDecoder.State state) |
protected Object |
SocksMessageEncoder.encode(ChannelHandlerContext ctx,
Channel channel,
Object msg) |
Modifier and Type | Method and Description |
---|---|
protected Object |
SpdyFrameDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer) |
protected Object |
SpdyHttpDecoder.decode(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 | Method and Description |
---|---|
ChannelFuture |
SslHandler.close(Channel channel)
Deprecated.
Use
SslHandler.close() instead. |
protected Object |
SslHandler.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer) |
ChannelFuture |
SslHandler.handshake(Channel channel)
Deprecated.
Use
SslHandler.handshake() instead. |
Modifier and Type | Method and Description |
---|---|
Channel |
DefaultIdleStateEvent.getChannel() |
Constructor and Description |
---|
DefaultIdleStateEvent(Channel channel,
IdleState state,
long lastActivityTimeMillis)
Creates a new instance.
|
Copyright © 2008-2014 The Netty Project. All Rights Reserved.