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.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.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.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.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.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 |
ChannelHandlerContext.getChannel()
Returns the
Channel that the ChannelPipeline belongs to. |
Channel |
UpstreamChannelStateEvent.getChannel() |
Channel |
ChannelPipeline.getChannel()
Returns the
Channel that this pipeline is attached to. |
Channel |
ChannelEvent.getChannel()
Returns the
Channel which is associated with this event. |
Channel |
DefaultChannelFuture.getChannel() |
Channel |
ChildChannelStateEvent.getChannel()
Returns the parent
Channel which is associated
with this event. |
Channel |
DefaultExceptionEvent.getChannel() |
Channel |
DownstreamMessageEvent.getChannel() |
Channel |
CompleteChannelFuture.getChannel() |
Channel |
DownstreamChannelStateEvent.getChannel() |
Channel |
ChannelFuture.getChannel()
Returns a channel where the I/O operation associated with this
future takes place.
|
Channel |
DefaultWriteCompletionEvent.getChannel() |
Channel |
DefaultChannelPipeline.getChannel() |
Channel |
DefaultChildChannelStateEvent.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 |
---|---|
void |
ChannelPipeline.attach(Channel channel,
ChannelSink sink)
Attaches this pipeline to the specified
Channel and
ChannelSink . |
void |
DefaultChannelPipeline.attach(Channel channel,
ChannelSink sink) |
static void |
Channels.bind(ChannelHandlerContext ctx,
Channel channel,
ChannelFuture future,
SocketAddress localAddress)
Deprecated.
Use
Channels.bind(ChannelHandlerContext, ChannelFuture, SocketAddress) instead.
Sends a "bind" request to the
ChannelDownstreamHandler which is placed in the closest
downstream from the handler associated with the specified
ChannelHandlerContext . |
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 . |
static void |
Channels.close(ChannelHandlerContext ctx,
Channel channel,
ChannelFuture future)
Deprecated.
Use
Channels.close(ChannelHandlerContext, ChannelFuture) instead.
Sends a "close" request to the
ChannelDownstreamHandler which is placed in the closest
downstream from the handler associated with the specified
ChannelHandlerContext . |
int |
AbstractChannel.compareTo(Channel o)
Compares the ID of the two channels.
|
static void |
Channels.connect(ChannelHandlerContext ctx,
Channel channel,
ChannelFuture future,
SocketAddress remoteAddress)
Deprecated.
Use
Channels.connect(ChannelHandlerContext, ChannelFuture, SocketAddress) instead.
Sends a "connect" request to the
ChannelDownstreamHandler which is placed in the closest
downstream from the handler associated with the specified
ChannelHandlerContext . |
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 void |
Channels.disconnect(ChannelHandlerContext ctx,
Channel channel,
ChannelFuture future)
Deprecated.
Use
Channels.disconnect(ChannelHandlerContext, ChannelFuture) instead.
Sends a "disconnect" request to the
ChannelDownstreamHandler which is placed in the closest
downstream from the handler associated with the specified
ChannelHandlerContext . |
static ChannelFuture |
Channels.failedFuture(Channel channel,
Throwable cause)
Creates a new
ChannelFuture which has failed already for the
specified Channel . |
static void |
Channels.fireChannelBound(ChannelHandlerContext ctx,
Channel channel,
SocketAddress localAddress)
Deprecated.
Use
Channels.fireChannelBound(ChannelHandlerContext, SocketAddress) instead.
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.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 void |
Channels.fireChannelClosed(ChannelHandlerContext ctx,
Channel channel)
Deprecated.
Use
Channels.fireChannelClosed(ChannelHandlerContext) .
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,
Channel channel,
SocketAddress remoteAddress)
Deprecated.
Use
Channels.fireChannelConnected(ChannelHandlerContext, SocketAddress) instead.
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.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 void |
Channels.fireChannelDisconnected(ChannelHandlerContext ctx,
Channel channel)
Deprecated.
Use
Channels.fireChannelDisconnected(ChannelHandlerContext) instead.
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(Channel channel)
Sends a
"channelInterestChanged" event to the first
ChannelUpstreamHandler in the ChannelPipeline of
the specified Channel . |
static void |
Channels.fireChannelInterestChanged(ChannelHandlerContext ctx,
Channel channel,
int interestOps)
Deprecated.
Use
Channels.fireChannelInterestChanged(ChannelHandlerContext) instead.
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.fireChannelInterestChanged(Channel channel,
int interestOps)
Deprecated.
Use
Channels.fireChannelInterestChanged(Channel) instead.
Sends a "channelInterestChanged" event to the first
ChannelUpstreamHandler in the ChannelPipeline of
the specified Channel . |
static void |
Channels.fireChannelOpen(Channel channel)
Sends a
"channelOpen" event to the first
ChannelUpstreamHandler in the ChannelPipeline of
the specified Channel . |
static void |
Channels.fireChannelOpen(ChannelHandlerContext ctx,
Channel channel)
Deprecated.
Use
Channels.fireChannelOpen(ChannelHandlerContext) instead.
Sends a "channelOpen" event to the
ChannelUpstreamHandler which is placed in the closest upstream
from the handler associated with the specified
ChannelHandlerContext .
Please note that this method does not trigger a
|
static void |
Channels.fireChannelUnbound(Channel channel)
Sends a
"channelUnbound" event to the first
ChannelUpstreamHandler in the ChannelPipeline of
the specified Channel . |
static void |
Channels.fireChannelUnbound(ChannelHandlerContext ctx,
Channel channel)
Deprecated.
Use
Channels.fireChannelUnbound(ChannelHandlerContext) instead.
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,
Channel channel,
Throwable cause)
Deprecated.
Use
Channels.fireExceptionCaught(ChannelHandlerContext, Throwable) instead.
Sends a "exceptionCaught" event to the
ChannelUpstreamHandler which is placed in the closest upstream
from the handler associated with the specified
ChannelHandlerContext . |
static void |
Channels.fireExceptionCaught(Channel channel,
Throwable cause)
Sends a
"exceptionCaught" event to the first
ChannelUpstreamHandler in the ChannelPipeline of
the specified Channel . |
static void |
Channels.fireMessageReceived(ChannelHandlerContext ctx,
Channel channel,
Object message)
Deprecated.
Use
Channels.fireMessageReceived(ChannelHandlerContext, Object) instead.
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,
Channel channel,
Object message,
SocketAddress remoteAddress)
Deprecated.
Use
Channels.fireMessageReceived(ChannelHandlerContext, Object, SocketAddress) instead.
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(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,
int amount)
Sends a
"writeComplete" event to the first
ChannelUpstreamHandler in the ChannelPipeline of
the specified Channel . |
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.
|
static MessageEvent |
Channels.messageEvent(Channel channel,
ChannelFuture future,
Object message)
Deprecated.
Instantiate
UpstreamMessageEvent or DownstreamMessageEvent directly instead.
Creates a new MessageEvent |
static MessageEvent |
Channels.messageEvent(Channel channel,
ChannelFuture future,
Object message,
SocketAddress remoteAddress)
Deprecated.
Instantiate
UpstreamMessageEvent or DownstreamMessageEvent directly instead.
Creates a new MessageEvent |
T |
ChannelLocal.remove(Channel channel)
Removes the variable.
|
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 void |
Channels.setInterestOps(ChannelHandlerContext ctx,
Channel channel,
ChannelFuture future,
int interestOps)
Deprecated.
Use
Channels.setInterestOps(ChannelHandlerContext, ChannelFuture, int) instead.
Sends a "setInterestOps" request to the
ChannelDownstreamHandler which is placed in the closest
downstream from the handler associated with the specified
ChannelHandlerContext . |
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 void |
Channels.unbind(ChannelHandlerContext ctx,
Channel channel,
ChannelFuture future)
Deprecated.
Use
Channels.unbind(ChannelHandlerContext, ChannelFuture) instead.
Sends a "unbind" 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,
Channel channel,
ChannelFuture future,
Object message)
Deprecated.
Use
Channels.write(ChannelHandlerContext, ChannelFuture, Object) instead.
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,
Channel channel,
ChannelFuture future,
Object message,
SocketAddress remoteAddress)
Deprecated.
Use
Channels.write(ChannelHandlerContext, ChannelFuture, Object, SocketAddress) instead.
Sends a "write" request to the
ChannelDownstreamHandler which is placed in the closest
downstream from the handler associated with the specified
ChannelHandlerContext . |
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.
|
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,
int 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.
|
UnfailingChannelFuture(Channel channel,
boolean cancellable)
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 . |
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 |
FixedLengthFrameDecoder.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 |
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 abstract Object |
OneToOneDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
Object msg) |
protected abstract Object |
OneToOneEncoder.encode(ChannelHandlerContext ctx,
Channel channel,
Object msg) |
Modifier and Type | Method and Description |
---|---|
protected Object |
ProtobufDecoder.decode(ChannelHandlerContext ctx,
Channel channel,
Object msg) |
protected Object |
ProtobufEncoder.encode(ChannelHandlerContext ctx,
Channel channel,
Object msg) |
Modifier and Type | Method and Description |
---|---|
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,
T state)
Decodes the received data so far into a frame when the channel is
disconnected.
|
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 |
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)
Sends an SSL
close_notify message to the specified channel and
destroys the underlying SSLEngine . |
protected Object |
SslHandler.decode(ChannelHandlerContext ctx,
Channel channel,
ChannelBuffer buffer) |
ChannelFuture |
SslHandler.handshake(Channel channel)
Starts an SSL / TLS handshake for the specified channel.
|
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-2013 JBoss, by Red Hat. All Rights Reserved.