| Package | Description | 
|---|---|
| io.undertow.client | |
| io.undertow.protocols.ssl | |
| io.undertow.servlet.websockets | |
| io.undertow.websockets.client | |
| io.undertow.websockets.spi | |
| org.jboss.remoting3 | 
 The base Remoting 3 API package. 
 | 
| org.wildfly.naming.client.remote | |
| org.xnio | 
 The main API package for XNIO. 
 | 
| org.xnio.http | |
| org.xnio.ssl | 
 Utility classes for using and implementing SSL within XNIO providers. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
IoFuture<ConnectedSslStreamChannel> | 
UndertowXnioSsl.connectSsl(XnioWorker worker,
          InetSocketAddress bindAddress,
          InetSocketAddress destination,
          ChannelListener<? super ConnectedSslStreamChannel> openListener,
          ChannelListener<? super BoundChannel> bindListener,
          OptionMap optionMap)  | 
IoFuture<SslConnection> | 
UndertowXnioSsl.openSslConnection(XnioIoThread ioThread,
                 InetSocketAddress bindAddress,
                 InetSocketAddress destination,
                 ChannelListener<? super SslConnection> openListener,
                 ChannelListener<? super BoundChannel> bindListener,
                 OptionMap optionMap)  | 
IoFuture<SslConnection> | 
UndertowXnioSsl.openSslConnection(XnioWorker worker,
                 InetSocketAddress bindAddress,
                 InetSocketAddress destination,
                 ChannelListener<? super SslConnection> openListener,
                 ChannelListener<? super BoundChannel> bindListener,
                 OptionMap optionMap)  | 
| Modifier and Type | Method and Description | 
|---|---|
IoFuture<byte[]> | 
ServletWebSocketHttpExchange.readRequestData()  | 
IoFuture<Void> | 
ServletWebSocketHttpExchange.sendData(ByteBuffer data)  | 
| Modifier and Type | Method and Description | 
|---|---|
IoFuture<WebSocketChannel> | 
WebSocketClient.ConnectionBuilder.connect()  | 
static IoFuture<WebSocketChannel> | 
WebSocketClient.connect(XnioWorker worker,
       ByteBufferPool bufferPool,
       OptionMap optionMap,
       URI uri,
       WebSocketVersion version)
Deprecated.  
 | 
static IoFuture<WebSocketChannel> | 
WebSocketClient.connect(XnioWorker worker,
       ByteBufferPool bufferPool,
       OptionMap optionMap,
       URI uri,
       WebSocketVersion version,
       WebSocketClientNegotiation clientNegotiation)
Deprecated.  
 | 
static IoFuture<WebSocketChannel> | 
WebSocketClient.connect(XnioWorker worker,
       XnioSsl ssl,
       ByteBufferPool bufferPool,
       OptionMap optionMap,
       InetSocketAddress bindAddress,
       URI uri,
       WebSocketVersion version,
       WebSocketClientNegotiation clientNegotiation,
       Set<ExtensionHandshake> clientExtensions)
Deprecated.  
 | 
static IoFuture<WebSocketChannel> | 
WebSocketClient.connect(XnioWorker worker,
       XnioSsl ssl,
       ByteBufferPool bufferPool,
       OptionMap optionMap,
       URI uri,
       WebSocketVersion version)
Deprecated.  
 | 
static IoFuture<WebSocketChannel> | 
WebSocketClient.connect(XnioWorker worker,
       XnioSsl ssl,
       ByteBufferPool bufferPool,
       OptionMap optionMap,
       URI uri,
       WebSocketVersion version,
       WebSocketClientNegotiation clientNegotiation)
Deprecated.  
 | 
static IoFuture<WebSocketChannel> | 
WebSocketClient.connect(XnioWorker worker,
       XnioSsl ssl,
       ByteBufferPool bufferPool,
       OptionMap optionMap,
       URI uri,
       WebSocketVersion version,
       WebSocketClientNegotiation clientNegotiation,
       Set<ExtensionHandshake> clientExtensions)
Deprecated.  
 | 
| Modifier and Type | Method and Description | 
|---|---|
IoFuture<byte[]> | 
WebSocketHttpExchange.readRequestData()
Gets the body of the request. 
 | 
IoFuture<byte[]> | 
BlockingWebSocketHttpServerExchange.readRequestData()  | 
IoFuture<byte[]> | 
AsyncWebSocketHttpServerExchange.readRequestData()  | 
IoFuture<Void> | 
WebSocketHttpExchange.sendData(ByteBuffer data)
Send some data 
 | 
IoFuture<Void> | 
BlockingWebSocketHttpServerExchange.sendData(ByteBuffer data)  | 
IoFuture<Void> | 
AsyncWebSocketHttpServerExchange.sendData(ByteBuffer data)  | 
| Modifier and Type | Method and Description | 
|---|---|
default IoFuture<Connection> | 
Endpoint.connect(URI destination)
Open a connection with a peer. 
 | 
IoFuture<Connection> | 
Endpoint.connect(URI destination,
       InetSocketAddress bindAddress,
       OptionMap connectOptions,
       org.wildfly.security.auth.client.AuthenticationContext authenticationContext)
Open a connection with a peer. 
 | 
IoFuture<Connection> | 
Endpoint.connect(URI destination,
       InetSocketAddress bindAddress,
       OptionMap connectOptions,
       SSLContext sslContext,
       org.wildfly.security.auth.client.AuthenticationConfiguration connectionConfiguration)
Open a connection with a peer. 
 | 
IoFuture<Connection> | 
Endpoint.connect(URI destination,
       OptionMap connectOptions)
Open a connection with a peer. 
 | 
IoFuture<Connection> | 
Endpoint.connect(URI destination,
       OptionMap connectOptions,
       org.wildfly.security.auth.client.AuthenticationContext authenticationContext)
Open a connection with a peer. 
 | 
IoFuture<T> | 
ClientServiceHandle.getClientService(Connection connection,
                OptionMap optionMap)
Get or establish the future client service for the given connection. 
 | 
default IoFuture<Connection> | 
Endpoint.getConnection(URI destination)
Get a possibly pre-existing connection to the destination. 
 | 
default IoFuture<Connection> | 
Endpoint.getConnection(URI destination,
             SSLContext sslContext,
             org.wildfly.security.auth.client.AuthenticationConfiguration authenticationConfiguration)
Get a possibly pre-existing connection to the destination. 
 | 
IoFuture<Connection> | 
Endpoint.getConnection(URI destination,
             SSLContext sslContext,
             org.wildfly.security.auth.client.AuthenticationConfiguration connectionConfiguration,
             org.wildfly.security.auth.client.AuthenticationConfiguration operateConfiguration)
Get a possibly pre-existing connection to the destination. 
 | 
default IoFuture<Connection> | 
Endpoint.getConnection(URI destination,
             String abstractType,
             String abstractTypeAuthority)
Get a possibly pre-existing connection to the destination. 
 | 
default IoFuture<Connection> | 
Endpoint.getConnectionIfExists(URI destination)
Get a pre-existing connection to the destination. 
 | 
IoFuture<Connection> | 
Endpoint.getConnectionIfExists(URI destination,
                     SSLContext sslContext,
                     org.wildfly.security.auth.client.AuthenticationConfiguration connectionConfiguration,
                     org.wildfly.security.auth.client.AuthenticationConfiguration operateConfiguration)
Get a pre-existing connection to the destination. 
 | 
default IoFuture<Connection> | 
Endpoint.getConnectionIfExists(URI destination,
                     String abstractType,
                     String abstractTypeAuthority)
Get a pre-existing connection to the destination. 
 | 
IoFuture<Channel> | 
Connection.openChannel(String serviceType,
           OptionMap optionMap)
Open a channel to a remote service on this connection. 
 | 
| Constructor and Description | 
|---|
ClientServiceHandle(String serviceName,
                   Function<Channel,IoFuture<T>> constructor)
Construct a new instance. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
abstract IoFuture<ConnectionPeerIdentity> | 
RemoteNamingProvider.getFuturePeerIdentity()
Get the future connection peer identity. 
 | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
AbstractConvertingIoFuture<T,D>
An  
IoFuture implementation that wraps a different type of IoFuture. | 
class  | 
AbstractIoFuture<T>
An abstract base class for  
IoFuture objects. | 
class  | 
FailedIoFuture<T>
An implementation of  
IoFuture that represents an immediately-failed operation. | 
class  | 
FinishedIoFuture<T>
An implementation of  
IoFuture that represents an immediately-successful operation. | 
| Modifier and Type | Field and Description | 
|---|---|
protected IoFuture<? extends D> | 
AbstractConvertingIoFuture.delegate
The delegate future result. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
IoFuture<? extends T> | 
ChannelDestination.accept(ChannelListener<? super T> openListener,
      ChannelListener<? super BoundChannel> bindListener)
Accept a connection. 
 | 
IoFuture<ConnectedMessageChannel> | 
XnioWorker.acceptDatagram(SocketAddress destination,
              ChannelListener<? super ConnectedMessageChannel> openListener,
              ChannelListener<? super BoundChannel> bindListener,
              OptionMap optionMap)
Deprecated.  
 | 
protected IoFuture<MessageConnection> | 
XnioIoThread.acceptLocalMessageConnection(LocalSocketAddress destination,
                            ChannelListener<? super MessageConnection> openListener,
                            ChannelListener<? super BoundChannel> bindListener,
                            OptionMap optionMap)
Implementation helper method to accept a local (UNIX domain) datagram connection. 
 | 
protected IoFuture<StreamConnection> | 
XnioIoThread.acceptLocalStreamConnection(LocalSocketAddress destination,
                           ChannelListener<? super StreamConnection> openListener,
                           ChannelListener<? super BoundChannel> bindListener,
                           OptionMap optionMap)
Implementation helper method to accept a local (UNIX domain) stream connection. 
 | 
IoFuture<MessageConnection> | 
XnioWorker.acceptMessageConnection(SocketAddress destination,
                       ChannelListener<? super MessageConnection> openListener,
                       ChannelListener<? super BoundChannel> bindListener,
                       OptionMap optionMap)  | 
IoFuture<MessageConnection> | 
XnioIoThread.acceptMessageConnection(SocketAddress destination,
                       ChannelListener<? super MessageConnection> openListener,
                       ChannelListener<? super BoundChannel> bindListener,
                       OptionMap optionMap)  | 
IoFuture<MessageConnection> | 
XnioIoFactory.acceptMessageConnection(SocketAddress destination,
                       ChannelListener<? super MessageConnection> openListener,
                       ChannelListener<? super BoundChannel> bindListener,
                       OptionMap optionMap)
Accept a message connection at a destination address. 
 | 
IoFuture<ConnectedStreamChannel> | 
XnioWorker.acceptStream(SocketAddress destination,
            ChannelListener<? super ConnectedStreamChannel> openListener,
            ChannelListener<? super BoundChannel> bindListener,
            OptionMap optionMap)
Deprecated.  
 | 
IoFuture<StreamConnection> | 
XnioWorker.acceptStreamConnection(SocketAddress destination,
                      ChannelListener<? super StreamConnection> openListener,
                      ChannelListener<? super BoundChannel> bindListener,
                      OptionMap optionMap)  | 
IoFuture<StreamConnection> | 
XnioIoThread.acceptStreamConnection(SocketAddress destination,
                      ChannelListener<? super StreamConnection> openListener,
                      ChannelListener<? super BoundChannel> bindListener,
                      OptionMap optionMap)  | 
IoFuture<StreamConnection> | 
XnioIoFactory.acceptStreamConnection(SocketAddress destination,
                      ChannelListener<? super StreamConnection> openListener,
                      ChannelListener<? super BoundChannel> bindListener,
                      OptionMap optionMap)
Accept a stream connection at a destination address. 
 | 
protected IoFuture<StreamConnection> | 
XnioIoThread.acceptTcpStreamConnection(InetSocketAddress destination,
                         ChannelListener<? super StreamConnection> openListener,
                         ChannelListener<? super BoundChannel> bindListener,
                         OptionMap optionMap)
Implementation helper method to accept a TCP connection. 
 | 
<A> IoFuture<T> | 
IoFuture.addNotifier(IoFuture.Notifier<? super T,A> notifier,
           A attachment)
Add a notifier to be called when this operation is complete. 
 | 
<A> IoFuture<T> | 
FinishedIoFuture.addNotifier(IoFuture.Notifier<? super T,A> notifier,
           A attachment)  | 
<A> IoFuture<T> | 
AbstractIoFuture.addNotifier(IoFuture.Notifier<? super T,A> notifier,
           A attachment)
Add a notifier to be called when this operation is complete. 
 | 
<A> IoFuture<T> | 
AbstractConvertingIoFuture.addNotifier(IoFuture.Notifier<? super T,A> notifier,
           A attachment)  | 
IoFuture<T> | 
IoFuture.cancel()
Cancel an operation. 
 | 
IoFuture<T> | 
FinishedIoFuture.cancel()
Cancel the operation. 
 | 
IoFuture<T> | 
FailedIoFuture.cancel()
Cancel the operation. 
 | 
IoFuture<T> | 
AbstractIoFuture.cancel()
Cancel an operation. 
 | 
IoFuture<T> | 
AbstractConvertingIoFuture.cancel()  | 
static <I,O> IoFuture<? extends O> | 
IoUtils.cast(IoFuture<I> parent,
    Class<O> type)
Create an  
IoFuture which wraps another IoFuture, but returns a different type. | 
IoFuture<ConnectedMessageChannel> | 
XnioWorker.connectDatagram(SocketAddress destination,
               ChannelListener<? super ConnectedMessageChannel> openListener,
               ChannelListener<? super BoundChannel> bindListener,
               OptionMap optionMap)
Deprecated.  
 | 
IoFuture<ConnectedMessageChannel> | 
XnioWorker.connectDatagram(SocketAddress bindAddress,
               SocketAddress destination,
               ChannelListener<? super ConnectedMessageChannel> openListener,
               ChannelListener<? super BoundChannel> bindListener,
               OptionMap optionMap)
Deprecated.  
 | 
IoFuture<ConnectedStreamChannel> | 
XnioWorker.connectStream(SocketAddress destination,
             ChannelListener<? super ConnectedStreamChannel> openListener,
             ChannelListener<? super BoundChannel> bindListener,
             OptionMap optionMap)
Deprecated.  
 | 
IoFuture<ConnectedStreamChannel> | 
XnioWorker.connectStream(SocketAddress destination,
             ChannelListener<? super ConnectedStreamChannel> openListener,
             OptionMap optionMap)
Deprecated.  
 | 
IoFuture<ConnectedStreamChannel> | 
XnioWorker.connectStream(SocketAddress bindAddress,
             SocketAddress destination,
             ChannelListener<? super ConnectedStreamChannel> openListener,
             ChannelListener<? super BoundChannel> bindListener,
             OptionMap optionMap)
Deprecated.  
 | 
protected IoFuture<? extends D> | 
AbstractConvertingIoFuture.getDelegate()  | 
IoFuture<T> | 
FutureResult.getIoFuture()
Get the  
IoFuture for this manager. | 
IoFuture<T> | 
ChannelSource.open(ChannelListener<? super T> openListener)
Open a channel. 
 | 
protected IoFuture<MessageConnection> | 
XnioIoThread.openLocalMessageConnection(LocalSocketAddress bindAddress,
                          LocalSocketAddress destinationAddress,
                          ChannelListener<? super MessageConnection> openListener,
                          OptionMap optionMap)
Implementation helper method to connect to a local (UNIX domain) server. 
 | 
protected IoFuture<StreamConnection> | 
XnioIoThread.openLocalStreamConnection(LocalSocketAddress bindAddress,
                         LocalSocketAddress destinationAddress,
                         ChannelListener<? super StreamConnection> openListener,
                         ChannelListener<? super BoundChannel> bindListener,
                         OptionMap optionMap)
Implementation helper method to connect to a local (UNIX domain) server. 
 | 
IoFuture<MessageConnection> | 
XnioWorker.openMessageConnection(SocketAddress destination,
                     ChannelListener<? super MessageConnection> openListener,
                     OptionMap optionMap)  | 
IoFuture<MessageConnection> | 
XnioIoThread.openMessageConnection(SocketAddress destination,
                     ChannelListener<? super MessageConnection> openListener,
                     OptionMap optionMap)  | 
IoFuture<MessageConnection> | 
XnioIoFactory.openMessageConnection(SocketAddress destination,
                     ChannelListener<? super MessageConnection> openListener,
                     OptionMap optionMap)
Connect to a remote message server. 
 | 
IoFuture<StreamConnection> | 
XnioWorker.openStreamConnection(SocketAddress destination,
                    ChannelListener<? super StreamConnection> openListener,
                    ChannelListener<? super BoundChannel> bindListener,
                    OptionMap optionMap)  | 
IoFuture<StreamConnection> | 
XnioIoThread.openStreamConnection(SocketAddress destination,
                    ChannelListener<? super StreamConnection> openListener,
                    ChannelListener<? super BoundChannel> bindListener,
                    OptionMap optionMap)  | 
IoFuture<StreamConnection> | 
XnioIoFactory.openStreamConnection(SocketAddress destination,
                    ChannelListener<? super StreamConnection> openListener,
                    ChannelListener<? super BoundChannel> bindListener,
                    OptionMap optionMap)
Connect to a remote stream server. 
 | 
IoFuture<StreamConnection> | 
XnioWorker.openStreamConnection(SocketAddress destination,
                    ChannelListener<? super StreamConnection> openListener,
                    OptionMap optionMap)  | 
IoFuture<StreamConnection> | 
XnioIoThread.openStreamConnection(SocketAddress destination,
                    ChannelListener<? super StreamConnection> openListener,
                    OptionMap optionMap)  | 
IoFuture<StreamConnection> | 
XnioIoFactory.openStreamConnection(SocketAddress destination,
                    ChannelListener<? super StreamConnection> openListener,
                    OptionMap optionMap)
Connect to a remote stream server. 
 | 
IoFuture<StreamConnection> | 
XnioWorker.openStreamConnection(SocketAddress bindAddress,
                    SocketAddress destination,
                    ChannelListener<? super StreamConnection> openListener,
                    ChannelListener<? super BoundChannel> bindListener,
                    OptionMap optionMap)  | 
IoFuture<StreamConnection> | 
XnioIoThread.openStreamConnection(SocketAddress bindAddress,
                    SocketAddress destination,
                    ChannelListener<? super StreamConnection> openListener,
                    ChannelListener<? super BoundChannel> bindListener,
                    OptionMap optionMap)  | 
IoFuture<StreamConnection> | 
XnioIoFactory.openStreamConnection(SocketAddress bindAddress,
                    SocketAddress destination,
                    ChannelListener<? super StreamConnection> openListener,
                    ChannelListener<? super BoundChannel> bindListener,
                    OptionMap optionMap)
Connect to a remote stream server. 
 | 
protected IoFuture<StreamConnection> | 
XnioIoThread.openTcpStreamConnection(InetSocketAddress bindAddress,
                       InetSocketAddress destinationAddress,
                       ChannelListener<? super StreamConnection> openListener,
                       ChannelListener<? super BoundChannel> bindListener,
                       OptionMap optionMap)
Implementation helper method to connect to a TCP server. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
static void | 
IoUtils.awaitAll(IoFuture<?>... futures)
Wait for all the futures to complete. 
 | 
static void | 
IoUtils.awaitAllInterruptibly(IoFuture<?>... futures)
Wait for all the futures to complete. 
 | 
static <I,O> IoFuture<? extends O> | 
IoUtils.cast(IoFuture<I> parent,
    Class<O> type)
Create an  
IoFuture which wraps another IoFuture, but returns a different type. | 
static <T> Future<T> | 
IoUtils.getFuture(IoFuture<T> ioFuture)
Get a  
java.util.concurrent-style Future instance wrapper for an IoFuture instance. | 
void | 
IoFuture.Notifier.notify(IoFuture<? extends T> ioFuture,
      A attachment)
Receive notification of the completion of an outstanding operation. 
 | 
void | 
IoFuture.HandlingNotifier.notify(IoFuture<? extends T> future,
      A attachment)
Receive notification of the completion of an outstanding operation. 
 | 
static void | 
IoUtils.safeClose(IoFuture<? extends Closeable> futureResource)
Close a future resource, logging an error if an error occurs. 
 | 
| Constructor and Description | 
|---|
AbstractConvertingIoFuture(IoFuture<? extends D> delegate)  | 
| Modifier and Type | Method and Description | 
|---|---|
static <T extends StreamConnection> | 
HttpUpgrade.performUpgrade(T connection,
              URI uri,
              Map<String,List<String>> headers,
              ChannelListener<? super StreamConnection> openListener,
              ExtendedHandshakeChecker handshakeChecker)
Performs a HTTP upgrade on an existing connection. 
 | 
static <T extends StreamConnection> | 
HttpUpgrade.performUpgrade(T connection,
              URI uri,
              Map<String,String> headers,
              ChannelListener<? super StreamConnection> openListener,
              HandshakeChecker handshakeChecker)
Performs a HTTP upgrade on an existing connection. 
 | 
static IoFuture<StreamConnection> | 
HttpUpgrade.performUpgrade(XnioWorker worker,
              InetSocketAddress bindAddress,
              URI uri,
              Map<String,List<String>> headers,
              ChannelListener<? super StreamConnection> openListener,
              ChannelListener<? super BoundChannel> bindListener,
              OptionMap optionMap,
              ExtendedHandshakeChecker handshakeChecker)
Connects to the target server using HTTP upgrade. 
 | 
static IoFuture<StreamConnection> | 
HttpUpgrade.performUpgrade(XnioWorker worker,
              InetSocketAddress bindAddress,
              URI uri,
              Map<String,String> headers,
              ChannelListener<? super StreamConnection> openListener,
              ChannelListener<? super BoundChannel> bindListener,
              OptionMap optionMap,
              HandshakeChecker handshakeChecker)
Connects to the target server using HTTP upgrade. 
 | 
static IoFuture<SslConnection> | 
HttpUpgrade.performUpgrade(XnioWorker worker,
              XnioSsl ssl,
              InetSocketAddress bindAddress,
              URI uri,
              Map<String,List<String>> headers,
              ChannelListener<? super SslConnection> openListener,
              ChannelListener<? super BoundChannel> bindListener,
              OptionMap optionMap,
              ExtendedHandshakeChecker handshakeChecker)
Perform a HTTP upgrade that results in a SSL secured connection. 
 | 
static IoFuture<SslConnection> | 
HttpUpgrade.performUpgrade(XnioWorker worker,
              XnioSsl ssl,
              InetSocketAddress bindAddress,
              URI uri,
              Map<String,String> headers,
              ChannelListener<? super SslConnection> openListener,
              ChannelListener<? super BoundChannel> bindListener,
              OptionMap optionMap,
              HandshakeChecker handshakeChecker)
Perform a HTTP upgrade that results in a SSL secured connection. 
 | 
Copyright © 2017 JBoss by Red Hat. All rights reserved.