Uses of Interface
org.jboss.netty.channel.ChannelFuture
-
Packages that use ChannelFuture 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 openChannel
s and perform bulk operations on them.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.channel.socket.oio Old blocking I/O based socket channel API implementation - recommended for a small number of connections (< 1000).org.jboss.netty.handler.codec.compression Encoder and decoder which compresses and decompressesChannelBuffer
s in a compression format such as zlib and gzip.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.spdy Encoder, decoder, session handler and their related message types for the SPDY protocol.org.jboss.netty.handler.ipfilter Implementation of a Ip based Filter handlers.
org.jboss.netty.handler.ssl org.jboss.netty.handler.timeout Adds support for read and write timeout and idle connection notification using aTimer
. -
-
Uses of ChannelFuture in org.jboss.netty.bootstrap
Methods in org.jboss.netty.bootstrap that return ChannelFuture Modifier and Type Method Description ChannelFuture
ClientBootstrap. bind(SocketAddress localAddress)
Attempts to bind a channel with the specifiedlocalAddress
.ChannelFuture
ServerBootstrap. bindAsync()
Bind a channel asynchronous to the local address specified in the current"localAddress"
option.ChannelFuture
ServerBootstrap. bindAsync(SocketAddress localAddress)
Bind a channel asynchronous to the specified local address.ChannelFuture
ClientBootstrap. connect()
Attempts a new connection with the current"remoteAddress"
and"localAddress"
option.ChannelFuture
ClientBootstrap. connect(SocketAddress remoteAddress)
Attempts a new connection with the specifiedremoteAddress
and the current"localAddress"
option.ChannelFuture
ClientBootstrap. connect(SocketAddress remoteAddress, SocketAddress localAddress)
Attempts a new connection with the specifiedremoteAddress
and the specifiedlocalAddress
.ChannelFuture
ConnectionlessBootstrap. connect()
Creates a new connected channel with the current"remoteAddress"
and"localAddress"
option.ChannelFuture
ConnectionlessBootstrap. connect(SocketAddress remoteAddress)
Creates a new connected channel with the specified"remoteAddress"
and the current"localAddress"
option.ChannelFuture
ConnectionlessBootstrap. connect(SocketAddress remoteAddress, SocketAddress localAddress)
Creates a new connected channel with the specified"remoteAddress"
and the specified"localAddress"
. -
Uses of ChannelFuture in org.jboss.netty.channel
Classes in org.jboss.netty.channel that implement ChannelFuture Modifier and Type Class Description class
CompleteChannelFuture
A skeletalChannelFuture
implementation which represents aChannelFuture
which has been completed already.class
DefaultChannelFuture
The defaultChannelFuture
implementation.class
FailedChannelFuture
TheCompleteChannelFuture
which is failed already.class
SucceededChannelFuture
TheCompleteChannelFuture
which is succeeded already.Methods in org.jboss.netty.channel that return ChannelFuture Modifier and Type Method Description ChannelFuture
ChannelFuture. await()
Waits for this future to be completed.ChannelFuture
CompleteChannelFuture. await()
ChannelFuture
DefaultChannelFuture. await()
ChannelFuture
ChannelFuture. awaitUninterruptibly()
Waits for this future to be completed without interruption.ChannelFuture
CompleteChannelFuture. awaitUninterruptibly()
ChannelFuture
DefaultChannelFuture. awaitUninterruptibly()
ChannelFuture
AbstractChannel. bind(SocketAddress localAddress)
ChannelFuture
Channel. bind(SocketAddress localAddress)
Binds this channel to the specified local address asynchronously.static ChannelFuture
Channels. bind(Channel channel, SocketAddress localAddress)
Sends a"bind"
request to the lastChannelDownstreamHandler
in theChannelPipeline
of the specifiedChannel
.ChannelFuture
AbstractChannel. close()
ChannelFuture
Channel. close()
Closes this channel asynchronously.static ChannelFuture
Channels. close(Channel channel)
Sends a"close"
request to the lastChannelDownstreamHandler
in theChannelPipeline
of the specifiedChannel
.ChannelFuture
AbstractChannel. connect(SocketAddress remoteAddress)
ChannelFuture
AbstractServerChannel. connect(SocketAddress remoteAddress)
ChannelFuture
Channel. connect(SocketAddress remoteAddress)
Connects this channel to the specified remote address asynchronously.static ChannelFuture
Channels. connect(Channel channel, SocketAddress remoteAddress)
Sends a"connect"
request to the lastChannelDownstreamHandler
in theChannelPipeline
of the specifiedChannel
.ChannelFuture
AbstractChannel. disconnect()
ChannelFuture
AbstractServerChannel. disconnect()
ChannelFuture
Channel. disconnect()
Disconnects this channel from the current remote address asynchronously.static ChannelFuture
Channels. disconnect(Channel channel)
Sends a"disconnect"
request to the lastChannelDownstreamHandler
in theChannelPipeline
of the specifiedChannel
.ChannelFuture
AbstractChannelSink. execute(ChannelPipeline pipeline, Runnable task)
This implementation just directly callRunnable.run()
.ChannelFuture
ChannelPipeline. execute(Runnable task)
Schedules the specified task to be executed in the I/O thread associated with this pipeline'sChannel
.ChannelFuture
ChannelSink. execute(ChannelPipeline pipeline, Runnable task)
Execute the givenRunnable
later in the io-thread.ChannelFuture
DefaultChannelPipeline. execute(Runnable task)
static ChannelFuture
Channels. failedFuture(Channel channel, Throwable cause)
Creates a newChannelFuture
which has failed already for the specifiedChannel
.static ChannelFuture
Channels. fireChannelClosedLater(Channel channel)
Sends a"channelClosed"
event to the firstChannelUpstreamHandler
in theChannelPipeline
of the specifiedChannel
once the io-thread runs again.static ChannelFuture
Channels. fireChannelDisconnectedLater(Channel channel)
Sends a"channelDisconnected"
event to the firstChannelUpstreamHandler
in theChannelPipeline
of the specifiedChannel
once the io-thread runs again.static ChannelFuture
Channels. fireChannelInterestChangedLater(Channel channel)
Sends a"channelInterestChanged"
event to the firstChannelUpstreamHandler
in theChannelPipeline
of the specifiedChannel
once the io-thread runs again.static ChannelFuture
Channels. fireChannelUnboundLater(Channel channel)
Sends a"channelUnbound"
event to the firstChannelUpstreamHandler
in theChannelPipeline
of the specifiedChannel
once the io-thread runs again.static ChannelFuture
Channels. fireExceptionCaughtLater(ChannelHandlerContext ctx, Throwable cause)
Sends a"exceptionCaught"
event to theChannelUpstreamHandler
which is placed in the closest upstream from the handler associated with the specifiedChannelHandlerContext
once the io-thread runs again.static ChannelFuture
Channels. fireExceptionCaughtLater(Channel channel, Throwable cause)
Sends a"exceptionCaught"
event to the firstChannelUpstreamHandler
in theChannelPipeline
of the specifiedChannel
once the io-thread runs again.static ChannelFuture
Channels. fireWriteCompleteLater(Channel channel, long amount)
Sends a"writeComplete"
event to the firstChannelUpstreamHandler
in theChannelPipeline
of the specifiedChannel
in the next io-thread.static ChannelFuture
Channels. future(Channel channel)
Creates a new non-cancellableChannelFuture
for the specifiedChannel
.static ChannelFuture
Channels. future(Channel channel, boolean cancellable)
Creates a newChannelFuture
for the specifiedChannel
.ChannelFuture
AbstractChannel. getCloseFuture()
ChannelFuture
Channel. getCloseFuture()
Returns theChannelFuture
which will be notified when this channel is closed.ChannelFuture
ChannelEvent. getFuture()
Returns theChannelFuture
which is associated with this event.ChannelFuture
DefaultChildChannelStateEvent. getFuture()
ChannelFuture
DefaultExceptionEvent. getFuture()
ChannelFuture
DefaultWriteCompletionEvent. getFuture()
ChannelFuture
DownstreamChannelStateEvent. getFuture()
ChannelFuture
DownstreamMessageEvent. getFuture()
ChannelFuture
UpstreamChannelStateEvent. getFuture()
ChannelFuture
UpstreamMessageEvent. getFuture()
protected ChannelFuture
AbstractChannel. getSucceededFuture()
Returns the cachedSucceededChannelFuture
instance.protected ChannelFuture
AbstractChannel. getUnsupportedOperationFuture()
Returns theFailedChannelFuture
whose cause is anUnsupportedOperationException
.ChannelFuture
AbstractChannel. setInterestOps(int interestOps)
ChannelFuture
AbstractServerChannel. setInterestOps(int interestOps)
ChannelFuture
Channel. setInterestOps(int interestOps)
Changes theinterestOps
of this channel asynchronously.static ChannelFuture
Channels. setInterestOps(Channel channel, int interestOps)
Sends a"setInterestOps"
request to the lastChannelDownstreamHandler
in theChannelPipeline
of the specifiedChannel
.ChannelFuture
AbstractChannel. setReadable(boolean readable)
ChannelFuture
Channel. setReadable(boolean readable)
Suspends or resumes the read operation of the I/O thread asynchronously.static ChannelFuture
Channels. succeededFuture(Channel channel)
Creates a newChannelFuture
which is already succeeded for the specifiedChannel
.ChannelFuture
ChannelFuture. sync()
Waits for this future until it is done, and rethrows the cause of the failure if this future failed.ChannelFuture
DefaultChannelFuture. sync()
ChannelFuture
FailedChannelFuture. sync()
ChannelFuture
SucceededChannelFuture. sync()
ChannelFuture
ChannelFuture. syncUninterruptibly()
Waits for this future until it is done, and rethrows the cause of the failure if this future failed.ChannelFuture
DefaultChannelFuture. syncUninterruptibly()
ChannelFuture
FailedChannelFuture. syncUninterruptibly()
ChannelFuture
SucceededChannelFuture. syncUninterruptibly()
ChannelFuture
AbstractChannel. unbind()
ChannelFuture
Channel. unbind()
Unbinds this channel from the current local address asynchronously.static ChannelFuture
Channels. unbind(Channel channel)
Sends a"unbind"
request to the lastChannelDownstreamHandler
in theChannelPipeline
of the specifiedChannel
.ChannelFuture
AbstractChannel. write(Object message)
ChannelFuture
AbstractChannel. write(Object message, SocketAddress remoteAddress)
ChannelFuture
AbstractServerChannel. write(Object message)
ChannelFuture
AbstractServerChannel. write(Object message, SocketAddress remoteAddress)
ChannelFuture
Channel. write(Object message)
Sends a message to this channel asynchronously.ChannelFuture
Channel. write(Object message, SocketAddress remoteAddress)
Sends a message to this channel asynchronously.static ChannelFuture
Channels. write(Channel channel, Object message)
Sends a"write"
request to the lastChannelDownstreamHandler
in theChannelPipeline
of the specifiedChannel
.static ChannelFuture
Channels. write(Channel channel, Object message, SocketAddress remoteAddress)
Sends a"write"
request to the lastChannelDownstreamHandler
in theChannelPipeline
of the specifiedChannel
.Methods in org.jboss.netty.channel with parameters of type ChannelFuture Modifier and Type Method Description static void
Channels. bind(ChannelHandlerContext ctx, ChannelFuture future, SocketAddress localAddress)
Sends a"bind"
request to theChannelDownstreamHandler
which is placed in the closest downstream from the handler associated with the specifiedChannelHandlerContext
.static void
Channels. close(ChannelHandlerContext ctx, ChannelFuture future)
Sends a"close"
request to theChannelDownstreamHandler
which is placed in the closest downstream from the handler associated with the specifiedChannelHandlerContext
.static void
Channels. connect(ChannelHandlerContext ctx, ChannelFuture future, SocketAddress remoteAddress)
Sends a"connect"
request to theChannelDownstreamHandler
which is placed in the closest downstream from the handler associated with the specifiedChannelHandlerContext
.static void
Channels. disconnect(ChannelHandlerContext ctx, ChannelFuture future)
Sends a"disconnect"
request to theChannelDownstreamHandler
which is placed in the closest downstream from the handler associated with the specifiedChannelHandlerContext
.void
ChannelFutureListener. operationComplete(ChannelFuture future)
Invoked when the I/O operation associated with theChannelFuture
has been completed.void
ChannelFutureNotifier. operationComplete(ChannelFuture cf)
void
ChannelFutureProgressListener. operationProgressed(ChannelFuture future, long amount, long current, long total)
Invoked when the I/O operation associated with theChannelFuture
has been progressed.static void
Channels. setInterestOps(ChannelHandlerContext ctx, ChannelFuture future, int interestOps)
Sends a"setInterestOps"
request to theChannelDownstreamHandler
which is placed in the closest downstream from the handler associated with the specifiedChannelHandlerContext
.static void
Channels. unbind(ChannelHandlerContext ctx, ChannelFuture future)
Sends a"unbind"
request to theChannelDownstreamHandler
which is placed in the closest downstream from the handler associated with the specifiedChannelHandlerContext
.static void
Channels. write(ChannelHandlerContext ctx, ChannelFuture future, Object message)
Sends a"write"
request to theChannelDownstreamHandler
which is placed in the closest downstream from the handler associated with the specifiedChannelHandlerContext
.static void
Channels. write(ChannelHandlerContext ctx, ChannelFuture future, Object message, SocketAddress remoteAddress)
Sends a"write"
request to theChannelDownstreamHandler
which is placed in the closest downstream from the handler associated with the specifiedChannelHandlerContext
.Constructors in org.jboss.netty.channel with parameters of type ChannelFuture Constructor Description ChannelFutureNotifier(ChannelFuture future)
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. -
Uses of ChannelFuture in org.jboss.netty.channel.group
Methods in org.jboss.netty.channel.group that return ChannelFuture Modifier and Type Method Description ChannelFuture
ChannelGroupFuture. find(Integer channelId)
Returns theChannelFuture
of the individual I/O operation which is associated with theChannel
whose ID matches the specified integer.ChannelFuture
ChannelGroupFuture. find(Channel channel)
Returns theChannelFuture
of the individual I/O operation which is associated with the specifiedChannel
.ChannelFuture
DefaultChannelGroupFuture. find(Integer channelId)
ChannelFuture
DefaultChannelGroupFuture. find(Channel channel)
Methods in org.jboss.netty.channel.group that return types with arguments of type ChannelFuture Modifier and Type Method Description Iterator<ChannelFuture>
ChannelGroupFuture. iterator()
Returns theIterator
that enumerates allChannelFuture
s which are associated with this future.Iterator<ChannelFuture>
DefaultChannelGroupFuture. iterator()
Constructor parameters in org.jboss.netty.channel.group with type arguments of type ChannelFuture Constructor Description DefaultChannelGroupFuture(ChannelGroup group, Collection<ChannelFuture> futures)
Creates a new instance. -
Uses of ChannelFuture in org.jboss.netty.channel.socket
Classes in org.jboss.netty.channel.socket that implement ChannelFuture Modifier and Type Class Description class
ChannelRunnableWrapper
Methods in org.jboss.netty.channel.socket that return ChannelFuture Modifier and Type Method Description ChannelFuture
DatagramChannel. joinGroup(InetAddress multicastAddress)
Joins a multicast group.ChannelFuture
DatagramChannel. joinGroup(InetSocketAddress multicastAddress, NetworkInterface networkInterface)
Joins the specified multicast group at the specified interface.ChannelFuture
DatagramChannel. leaveGroup(InetAddress multicastAddress)
Leaves a multicast group.ChannelFuture
DatagramChannel. leaveGroup(InetSocketAddress multicastAddress, NetworkInterface networkInterface)
Leaves a multicast group on a specified local interface. -
Uses of ChannelFuture in org.jboss.netty.channel.socket.nio
Methods in org.jboss.netty.channel.socket.nio that return ChannelFuture Modifier and Type Method Description ChannelFuture
NioDatagramChannel. block(InetAddress multicastAddress, InetAddress sourceToBlock)
Block the given sourceToBlock address for the given multicastAddressChannelFuture
NioDatagramChannel. block(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress sourceToBlock)
Block the given sourceToBlock address for the given multicastAddress on the given networkInterfaceChannelFuture
AbstractNioChannelSink. execute(ChannelPipeline pipeline, Runnable task)
ChannelFuture
NioDatagramChannel. joinGroup(InetAddress multicastAddress)
ChannelFuture
NioDatagramChannel. joinGroup(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress source)
Joins the specified multicast group at the specified interface using the specified source.ChannelFuture
NioDatagramChannel. joinGroup(InetSocketAddress multicastAddress, NetworkInterface networkInterface)
ChannelFuture
NioDatagramChannel. leaveGroup(InetAddress multicastAddress)
ChannelFuture
NioDatagramChannel. leaveGroup(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress source)
Leave the specified multicast group at the specified interface using the specified source.ChannelFuture
NioDatagramChannel. leaveGroup(InetSocketAddress multicastAddress, NetworkInterface networkInterface)
ChannelFuture
NioDatagramChannel. write(Object message, SocketAddress remoteAddress)
ChannelFuture
NioSocketChannel. write(Object message, SocketAddress remoteAddress)
Methods in org.jboss.netty.channel.socket.nio with parameters of type ChannelFuture Modifier and Type Method Description protected Runnable
NioClientBoss. createRegisterTask(Channel channel, ChannelFuture future)
protected Runnable
NioDatagramWorker. createRegisterTask(Channel channel, ChannelFuture future)
protected Runnable
NioServerBoss. createRegisterTask(Channel channel, ChannelFuture future)
protected Runnable
NioWorker. createRegisterTask(Channel channel, ChannelFuture future)
void
NioSelector. register(Channel channel, ChannelFuture future)
-
Uses of ChannelFuture in org.jboss.netty.channel.socket.oio
Methods in org.jboss.netty.channel.socket.oio that return ChannelFuture Modifier and Type Method Description ChannelFuture
AbstractOioChannelSink. execute(ChannelPipeline pipeline, Runnable task)
-
Uses of ChannelFuture in org.jboss.netty.handler.codec.compression
Methods in org.jboss.netty.handler.codec.compression that return ChannelFuture Modifier and Type Method Description ChannelFuture
JdkZlibEncoder. close()
ChannelFuture
ZlibEncoder. close()
-
Uses of ChannelFuture in org.jboss.netty.handler.codec.http.websocketx
Methods in org.jboss.netty.handler.codec.http.websocketx that return ChannelFuture Modifier and Type Method Description abstract ChannelFuture
WebSocketServerHandshaker. close(Channel channel, CloseWebSocketFrame frame)
Performs the closing handshakeChannelFuture
WebSocketServerHandshaker00. close(Channel channel, CloseWebSocketFrame frame)
Echo back the closing frameChannelFuture
WebSocketServerHandshaker07. close(Channel channel, CloseWebSocketFrame frame)
Echo back the closing frame and close the connectionChannelFuture
WebSocketServerHandshaker08. close(Channel channel, CloseWebSocketFrame frame)
Echo back the closing frame and close the connectionChannelFuture
WebSocketServerHandshaker13. close(Channel channel, CloseWebSocketFrame frame)
Echo back the closing frame and close the connectionabstract ChannelFuture
WebSocketClientHandshaker. handshake(Channel channel)
Begins the opening handshakeChannelFuture
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 handshakeChannelFuture
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.ChannelFuture
WebSocketServerHandshakerFactory. sendUnsupportedWebSocketVersionResponse(Channel channel)
Return that we need cannot not support the web socket versionprotected ChannelFuture
WebSocketServerHandshaker. writeHandshakeResponse(Channel channel, HttpResponse res, ChannelHandler encoder, ChannelHandler decoder)
Upgrades the connection and send the handshake response. -
Uses of ChannelFuture in org.jboss.netty.handler.codec.spdy
Methods in org.jboss.netty.handler.codec.spdy with parameters of type ChannelFuture Modifier and Type Method Description protected void
SpdyHttpEncoder. writeChunk(ChannelHandlerContext ctx, ChannelFuture future, int streamId, HttpChunk chunk, SocketAddress remoteAddress)
Writes an HTTP chunk downstream as one or more SPDY frames. -
Uses of ChannelFuture in org.jboss.netty.handler.ipfilter
Methods in org.jboss.netty.handler.ipfilter that return ChannelFuture Modifier and Type Method Description 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().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().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(). -
Uses of ChannelFuture in org.jboss.netty.handler.ssl
Methods in org.jboss.netty.handler.ssl that return ChannelFuture Modifier and Type Method Description ChannelFuture
SslHandler. close()
Sends an SSLclose_notify
message to the specified channel and destroys the underlyingSSLEngine
.ChannelFuture
SslHandler. getSSLEngineInboundCloseFuture()
Return theChannelFuture
that will get notified if the inbound of theSSLEngine
will get closed.ChannelFuture
SslHandler. handshake()
Starts an SSL / TLS handshake for the specified channel. -
Uses of ChannelFuture in org.jboss.netty.handler.timeout
Methods in org.jboss.netty.handler.timeout that return ChannelFuture Modifier and Type Method Description ChannelFuture
DefaultIdleStateEvent. getFuture()
-