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 openChannels 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 decompressesChannelBuffers 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 ChannelFutureClientBootstrap. bind(SocketAddress localAddress)Attempts to bind a channel with the specifiedlocalAddress.ChannelFutureServerBootstrap. bindAsync()Bind a channel asynchronous to the local address specified in the current"localAddress"option.ChannelFutureServerBootstrap. bindAsync(SocketAddress localAddress)Bind a channel asynchronous to the specified local address.ChannelFutureClientBootstrap. connect()Attempts a new connection with the current"remoteAddress"and"localAddress"option.ChannelFutureClientBootstrap. connect(SocketAddress remoteAddress)Attempts a new connection with the specifiedremoteAddressand the current"localAddress"option.ChannelFutureClientBootstrap. connect(SocketAddress remoteAddress, SocketAddress localAddress)Attempts a new connection with the specifiedremoteAddressand the specifiedlocalAddress.ChannelFutureConnectionlessBootstrap. connect()Creates a new connected channel with the current"remoteAddress"and"localAddress"option.ChannelFutureConnectionlessBootstrap. connect(SocketAddress remoteAddress)Creates a new connected channel with the specified"remoteAddress"and the current"localAddress"option.ChannelFutureConnectionlessBootstrap. 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 classCompleteChannelFutureA skeletalChannelFutureimplementation which represents aChannelFuturewhich has been completed already.classDefaultChannelFutureThe defaultChannelFutureimplementation.classFailedChannelFutureTheCompleteChannelFuturewhich is failed already.classSucceededChannelFutureTheCompleteChannelFuturewhich is succeeded already.Methods in org.jboss.netty.channel that return ChannelFuture Modifier and Type Method Description ChannelFutureChannelFuture. await()Waits for this future to be completed.ChannelFutureCompleteChannelFuture. await()ChannelFutureDefaultChannelFuture. await()ChannelFutureChannelFuture. awaitUninterruptibly()Waits for this future to be completed without interruption.ChannelFutureCompleteChannelFuture. awaitUninterruptibly()ChannelFutureDefaultChannelFuture. awaitUninterruptibly()ChannelFutureAbstractChannel. bind(SocketAddress localAddress)ChannelFutureChannel. bind(SocketAddress localAddress)Binds this channel to the specified local address asynchronously.static ChannelFutureChannels. bind(Channel channel, SocketAddress localAddress)Sends a"bind"request to the lastChannelDownstreamHandlerin theChannelPipelineof the specifiedChannel.ChannelFutureAbstractChannel. close()ChannelFutureChannel. close()Closes this channel asynchronously.static ChannelFutureChannels. close(Channel channel)Sends a"close"request to the lastChannelDownstreamHandlerin theChannelPipelineof the specifiedChannel.ChannelFutureAbstractChannel. connect(SocketAddress remoteAddress)ChannelFutureAbstractServerChannel. connect(SocketAddress remoteAddress)ChannelFutureChannel. connect(SocketAddress remoteAddress)Connects this channel to the specified remote address asynchronously.static ChannelFutureChannels. connect(Channel channel, SocketAddress remoteAddress)Sends a"connect"request to the lastChannelDownstreamHandlerin theChannelPipelineof the specifiedChannel.ChannelFutureAbstractChannel. disconnect()ChannelFutureAbstractServerChannel. disconnect()ChannelFutureChannel. disconnect()Disconnects this channel from the current remote address asynchronously.static ChannelFutureChannels. disconnect(Channel channel)Sends a"disconnect"request to the lastChannelDownstreamHandlerin theChannelPipelineof the specifiedChannel.ChannelFutureAbstractChannelSink. execute(ChannelPipeline pipeline, Runnable task)This implementation just directly callRunnable.run().ChannelFutureChannelPipeline. execute(Runnable task)Schedules the specified task to be executed in the I/O thread associated with this pipeline'sChannel.ChannelFutureChannelSink. execute(ChannelPipeline pipeline, Runnable task)Execute the givenRunnablelater in the io-thread.ChannelFutureDefaultChannelPipeline. execute(Runnable task)static ChannelFutureChannels. failedFuture(Channel channel, Throwable cause)Creates a newChannelFuturewhich has failed already for the specifiedChannel.static ChannelFutureChannels. fireChannelClosedLater(Channel channel)Sends a"channelClosed"event to the firstChannelUpstreamHandlerin theChannelPipelineof the specifiedChannelonce the io-thread runs again.static ChannelFutureChannels. fireChannelDisconnectedLater(Channel channel)Sends a"channelDisconnected"event to the firstChannelUpstreamHandlerin theChannelPipelineof the specifiedChannelonce the io-thread runs again.static ChannelFutureChannels. fireChannelInterestChangedLater(Channel channel)Sends a"channelInterestChanged"event to the firstChannelUpstreamHandlerin theChannelPipelineof the specifiedChannelonce the io-thread runs again.static ChannelFutureChannels. fireChannelUnboundLater(Channel channel)Sends a"channelUnbound"event to the firstChannelUpstreamHandlerin theChannelPipelineof the specifiedChannelonce the io-thread runs again.static ChannelFutureChannels. fireExceptionCaughtLater(ChannelHandlerContext ctx, Throwable cause)Sends a"exceptionCaught"event to theChannelUpstreamHandlerwhich is placed in the closest upstream from the handler associated with the specifiedChannelHandlerContextonce the io-thread runs again.static ChannelFutureChannels. fireExceptionCaughtLater(Channel channel, Throwable cause)Sends a"exceptionCaught"event to the firstChannelUpstreamHandlerin theChannelPipelineof the specifiedChannelonce the io-thread runs again.static ChannelFutureChannels. fireWriteCompleteLater(Channel channel, long amount)Sends a"writeComplete"event to the firstChannelUpstreamHandlerin theChannelPipelineof the specifiedChannelin the next io-thread.static ChannelFutureChannels. future(Channel channel)Creates a new non-cancellableChannelFuturefor the specifiedChannel.static ChannelFutureChannels. future(Channel channel, boolean cancellable)Creates a newChannelFuturefor the specifiedChannel.ChannelFutureAbstractChannel. getCloseFuture()ChannelFutureChannel. getCloseFuture()Returns theChannelFuturewhich will be notified when this channel is closed.ChannelFutureChannelEvent. getFuture()Returns theChannelFuturewhich is associated with this event.ChannelFutureDefaultChildChannelStateEvent. getFuture()ChannelFutureDefaultExceptionEvent. getFuture()ChannelFutureDefaultWriteCompletionEvent. getFuture()ChannelFutureDownstreamChannelStateEvent. getFuture()ChannelFutureDownstreamMessageEvent. getFuture()ChannelFutureUpstreamChannelStateEvent. getFuture()ChannelFutureUpstreamMessageEvent. getFuture()protected ChannelFutureAbstractChannel. getSucceededFuture()Returns the cachedSucceededChannelFutureinstance.protected ChannelFutureAbstractChannel. getUnsupportedOperationFuture()Returns theFailedChannelFuturewhose cause is anUnsupportedOperationException.ChannelFutureAbstractChannel. setInterestOps(int interestOps)ChannelFutureAbstractServerChannel. setInterestOps(int interestOps)ChannelFutureChannel. setInterestOps(int interestOps)Changes theinterestOpsof this channel asynchronously.static ChannelFutureChannels. setInterestOps(Channel channel, int interestOps)Sends a"setInterestOps"request to the lastChannelDownstreamHandlerin theChannelPipelineof the specifiedChannel.ChannelFutureAbstractChannel. setReadable(boolean readable)ChannelFutureChannel. setReadable(boolean readable)Suspends or resumes the read operation of the I/O thread asynchronously.static ChannelFutureChannels. succeededFuture(Channel channel)Creates a newChannelFuturewhich is already succeeded for the specifiedChannel.ChannelFutureChannelFuture. sync()Waits for this future until it is done, and rethrows the cause of the failure if this future failed.ChannelFutureDefaultChannelFuture. sync()ChannelFutureFailedChannelFuture. sync()ChannelFutureSucceededChannelFuture. sync()ChannelFutureChannelFuture. syncUninterruptibly()Waits for this future until it is done, and rethrows the cause of the failure if this future failed.ChannelFutureDefaultChannelFuture. syncUninterruptibly()ChannelFutureFailedChannelFuture. syncUninterruptibly()ChannelFutureSucceededChannelFuture. syncUninterruptibly()ChannelFutureAbstractChannel. unbind()ChannelFutureChannel. unbind()Unbinds this channel from the current local address asynchronously.static ChannelFutureChannels. unbind(Channel channel)Sends a"unbind"request to the lastChannelDownstreamHandlerin theChannelPipelineof the specifiedChannel.ChannelFutureAbstractChannel. write(Object message)ChannelFutureAbstractChannel. write(Object message, SocketAddress remoteAddress)ChannelFutureAbstractServerChannel. write(Object message)ChannelFutureAbstractServerChannel. write(Object message, SocketAddress remoteAddress)ChannelFutureChannel. write(Object message)Sends a message to this channel asynchronously.ChannelFutureChannel. write(Object message, SocketAddress remoteAddress)Sends a message to this channel asynchronously.static ChannelFutureChannels. write(Channel channel, Object message)Sends a"write"request to the lastChannelDownstreamHandlerin theChannelPipelineof the specifiedChannel.static ChannelFutureChannels. write(Channel channel, Object message, SocketAddress remoteAddress)Sends a"write"request to the lastChannelDownstreamHandlerin theChannelPipelineof the specifiedChannel.Methods in org.jboss.netty.channel with parameters of type ChannelFuture Modifier and Type Method Description static voidChannels. bind(ChannelHandlerContext ctx, ChannelFuture future, SocketAddress localAddress)Sends a"bind"request to theChannelDownstreamHandlerwhich is placed in the closest downstream from the handler associated with the specifiedChannelHandlerContext.static voidChannels. close(ChannelHandlerContext ctx, ChannelFuture future)Sends a"close"request to theChannelDownstreamHandlerwhich is placed in the closest downstream from the handler associated with the specifiedChannelHandlerContext.static voidChannels. connect(ChannelHandlerContext ctx, ChannelFuture future, SocketAddress remoteAddress)Sends a"connect"request to theChannelDownstreamHandlerwhich is placed in the closest downstream from the handler associated with the specifiedChannelHandlerContext.static voidChannels. disconnect(ChannelHandlerContext ctx, ChannelFuture future)Sends a"disconnect"request to theChannelDownstreamHandlerwhich is placed in the closest downstream from the handler associated with the specifiedChannelHandlerContext.voidChannelFutureListener. operationComplete(ChannelFuture future)Invoked when the I/O operation associated with theChannelFuturehas been completed.voidChannelFutureNotifier. operationComplete(ChannelFuture cf)voidChannelFutureProgressListener. operationProgressed(ChannelFuture future, long amount, long current, long total)Invoked when the I/O operation associated with theChannelFuturehas been progressed.static voidChannels. setInterestOps(ChannelHandlerContext ctx, ChannelFuture future, int interestOps)Sends a"setInterestOps"request to theChannelDownstreamHandlerwhich is placed in the closest downstream from the handler associated with the specifiedChannelHandlerContext.static voidChannels. unbind(ChannelHandlerContext ctx, ChannelFuture future)Sends a"unbind"request to theChannelDownstreamHandlerwhich is placed in the closest downstream from the handler associated with the specifiedChannelHandlerContext.static voidChannels. write(ChannelHandlerContext ctx, ChannelFuture future, Object message)Sends a"write"request to theChannelDownstreamHandlerwhich is placed in the closest downstream from the handler associated with the specifiedChannelHandlerContext.static voidChannels. write(ChannelHandlerContext ctx, ChannelFuture future, Object message, SocketAddress remoteAddress)Sends a"write"request to theChannelDownstreamHandlerwhich 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 ChannelFutureChannelGroupFuture. find(Integer channelId)Returns theChannelFutureof the individual I/O operation which is associated with theChannelwhose ID matches the specified integer.ChannelFutureChannelGroupFuture. find(Channel channel)Returns theChannelFutureof the individual I/O operation which is associated with the specifiedChannel.ChannelFutureDefaultChannelGroupFuture. find(Integer channelId)ChannelFutureDefaultChannelGroupFuture. 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 theIteratorthat enumerates allChannelFutures 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 classChannelRunnableWrapperMethods in org.jboss.netty.channel.socket that return ChannelFuture Modifier and Type Method Description ChannelFutureDatagramChannel. joinGroup(InetAddress multicastAddress)Joins a multicast group.ChannelFutureDatagramChannel. joinGroup(InetSocketAddress multicastAddress, NetworkInterface networkInterface)Joins the specified multicast group at the specified interface.ChannelFutureDatagramChannel. leaveGroup(InetAddress multicastAddress)Leaves a multicast group.ChannelFutureDatagramChannel. 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 ChannelFutureNioDatagramChannel. block(InetAddress multicastAddress, InetAddress sourceToBlock)Block the given sourceToBlock address for the given multicastAddressChannelFutureNioDatagramChannel. block(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress sourceToBlock)Block the given sourceToBlock address for the given multicastAddress on the given networkInterfaceChannelFutureAbstractNioChannelSink. execute(ChannelPipeline pipeline, Runnable task)ChannelFutureNioDatagramChannel. joinGroup(InetAddress multicastAddress)ChannelFutureNioDatagramChannel. joinGroup(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress source)Joins the specified multicast group at the specified interface using the specified source.ChannelFutureNioDatagramChannel. joinGroup(InetSocketAddress multicastAddress, NetworkInterface networkInterface)ChannelFutureNioDatagramChannel. leaveGroup(InetAddress multicastAddress)ChannelFutureNioDatagramChannel. leaveGroup(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress source)Leave the specified multicast group at the specified interface using the specified source.ChannelFutureNioDatagramChannel. leaveGroup(InetSocketAddress multicastAddress, NetworkInterface networkInterface)ChannelFutureNioDatagramChannel. write(Object message, SocketAddress remoteAddress)ChannelFutureNioSocketChannel. write(Object message, SocketAddress remoteAddress)Methods in org.jboss.netty.channel.socket.nio with parameters of type ChannelFuture Modifier and Type Method Description protected RunnableNioClientBoss. createRegisterTask(Channel channel, ChannelFuture future)protected RunnableNioDatagramWorker. createRegisterTask(Channel channel, ChannelFuture future)protected RunnableNioServerBoss. createRegisterTask(Channel channel, ChannelFuture future)protected RunnableNioWorker. createRegisterTask(Channel channel, ChannelFuture future)voidNioSelector. 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 ChannelFutureAbstractOioChannelSink. 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 ChannelFutureJdkZlibEncoder. close()ChannelFutureZlibEncoder. 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 ChannelFutureWebSocketServerHandshaker. close(Channel channel, CloseWebSocketFrame frame)Performs the closing handshakeChannelFutureWebSocketServerHandshaker00. close(Channel channel, CloseWebSocketFrame frame)Echo back the closing frameChannelFutureWebSocketServerHandshaker07. close(Channel channel, CloseWebSocketFrame frame)Echo back the closing frame and close the connectionChannelFutureWebSocketServerHandshaker08. close(Channel channel, CloseWebSocketFrame frame)Echo back the closing frame and close the connectionChannelFutureWebSocketServerHandshaker13. close(Channel channel, CloseWebSocketFrame frame)Echo back the closing frame and close the connectionabstract ChannelFutureWebSocketClientHandshaker. handshake(Channel channel)Begins the opening handshakeChannelFutureWebSocketClientHandshaker00. handshake(Channel channel)Sends the opening request to the server:ChannelFutureWebSocketClientHandshaker07. handshake(Channel channel)/**ChannelFutureWebSocketClientHandshaker08. handshake(Channel channel)/**ChannelFutureWebSocketClientHandshaker13. handshake(Channel channel)/**abstract ChannelFutureWebSocketServerHandshaker. handshake(Channel channel, HttpRequest req)Performs the opening handshakeChannelFutureWebSocketServerHandshaker00. handshake(Channel channel, HttpRequest req)Handle the web socket handshake for the web socket specification HyBi version 0 and lower.ChannelFutureWebSocketServerHandshaker07. handshake(Channel channel, HttpRequest req)Handle the web socket handshake for the web socket specification HyBi version 7.ChannelFutureWebSocketServerHandshaker08. handshake(Channel channel, HttpRequest req)Handle the web socket handshake for the web socket specification HyBi version 8 to 10.ChannelFutureWebSocketServerHandshaker13. handshake(Channel channel, HttpRequest req)Handle the web socket handshake for the web socket specification HyBi versions 13-17.ChannelFutureWebSocketServerHandshakerFactory. sendUnsupportedWebSocketVersionResponse(Channel channel)Return that we need cannot not support the web socket versionprotected ChannelFutureWebSocketServerHandshaker. 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 voidSpdyHttpEncoder. 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 ChannelFutureIpFilterListener. 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 ChannelFutureIpFilteringHandlerImpl. handleAllowedChannel(ChannelHandlerContext ctx, ChannelEvent e, InetSocketAddress inetSocketAddress)protected ChannelFutureIpFilteringHandlerImpl. 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().ChannelFutureIpFilterListener. 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 ChannelFutureSslHandler. close()Sends an SSLclose_notifymessage to the specified channel and destroys the underlyingSSLEngine.ChannelFutureSslHandler. getSSLEngineInboundCloseFuture()Return theChannelFuturethat will get notified if the inbound of theSSLEnginewill get closed.ChannelFutureSslHandler. 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 ChannelFutureDefaultIdleStateEvent. getFuture()
-