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[]> |
BlockingWebSocketHttpServerExchange.readRequestData() |
IoFuture<byte[]> |
WebSocketHttpExchange.readRequestData()
Gets the body of the request.
|
IoFuture<byte[]> |
AsyncWebSocketHttpServerExchange.readRequestData() |
IoFuture<Void> |
BlockingWebSocketHttpServerExchange.sendData(ByteBuffer data) |
IoFuture<Void> |
WebSocketHttpExchange.sendData(ByteBuffer data)
Send some data
|
IoFuture<Void> |
AsyncWebSocketHttpServerExchange.sendData(ByteBuffer data) |
Modifier and Type | Class and Description |
---|---|
class |
ToConnectionFuture |
Modifier and Type | Method and Description |
---|---|
IoFuture<ConnectionPeerIdentity> |
ConnectionPeerIdentityContext.authenticateAsync(AuthenticationConfiguration configuration) |
default IoFuture<Connection> |
Endpoint.connect(URI destination)
Open an unshared connection with a peer.
|
IoFuture<Connection> |
LegacyEndpoint.connect(URI destination,
InetSocketAddress bindAddress,
OptionMap connectOptions,
AuthenticationContext authenticationContext)
Deprecated.
|
IoFuture<Connection> |
Endpoint.connect(URI destination,
InetSocketAddress bindAddress,
OptionMap connectOptions,
AuthenticationContext authenticationContext)
Open an unshared connection with a peer.
|
IoFuture<Connection> |
LegacyEndpoint.connect(URI destination,
InetSocketAddress bindAddress,
OptionMap connectOptions,
SSLContext sslContext,
AuthenticationConfiguration connectionConfiguration)
Deprecated.
|
IoFuture<Connection> |
Endpoint.connect(URI destination,
InetSocketAddress bindAddress,
OptionMap connectOptions,
SSLContext sslContext,
AuthenticationConfiguration connectionConfiguration)
Open an unshared connection with a peer.
|
IoFuture<Connection> |
LegacyEndpoint.connect(URI destination,
OptionMap connectOptions)
Deprecated.
|
IoFuture<Connection> |
Endpoint.connect(URI destination,
OptionMap connectOptions)
Open an unshared connection with a peer.
|
IoFuture<Connection> |
LegacyEndpoint.connect(URI destination,
OptionMap connectOptions,
AuthenticationContext authenticationContext)
Deprecated.
|
IoFuture<Connection> |
Endpoint.connect(URI destination,
OptionMap connectOptions,
AuthenticationContext authenticationContext)
Open an unshared connection with a peer.
|
IoFuture<Connection> |
LegacyEndpoint.connect(URI destination,
OptionMap connectOptions,
CallbackHandler callbackHandler)
Deprecated.
|
IoFuture<Connection> |
Endpoint.connect(URI destination,
OptionMap connectOptions,
CallbackHandler callbackHandler)
Deprecated.
|
IoFuture<T> |
ClientServiceHandle.getClientService(Connection connection,
OptionMap optionMap)
Get or establish the future client service for the given connection.
|
IoFuture<ConnectionPeerIdentity> |
LegacyEndpoint.getConnectedIdentity(URI destination,
SSLContext sslContext,
AuthenticationConfiguration authenticationConfiguration)
Deprecated.
|
IoFuture<ConnectionPeerIdentity> |
Endpoint.getConnectedIdentity(URI destination,
SSLContext sslContext,
AuthenticationConfiguration authenticationConfiguration)
Get a possibly shared, possibly existing connection to the destination.
|
default IoFuture<ConnectionPeerIdentity> |
Endpoint.getConnectedIdentity(URI destination,
String abstractType,
String abstractTypeAuthority)
Get a possibly shared, possibly existing connection to the destination.
|
default IoFuture<ConnectionPeerIdentity> |
Endpoint.getConnectedIdentity(URI destination,
String abstractType,
String abstractTypeAuthority,
AuthenticationContext context)
Get a possibly shared, possibly existing connection to the destination.
|
IoFuture<ConnectionPeerIdentity> |
LegacyEndpoint.getConnectedIdentityIfExists(URI destination,
SSLContext sslContext,
AuthenticationConfiguration authenticationConfiguration)
Deprecated.
|
IoFuture<ConnectionPeerIdentity> |
Endpoint.getConnectedIdentityIfExists(URI destination,
SSLContext sslContext,
AuthenticationConfiguration authenticationConfiguration)
Get a possibly shared, possibly existing connection to the destination, if the connection was already established.
|
default IoFuture<ConnectionPeerIdentity> |
Endpoint.getConnectedIdentityIfExists(URI destination,
String abstractType,
String abstractTypeAuthority,
AuthenticationContext context)
Get a possibly shared, possibly existing connection to the destination, if the connection was already established.
|
default IoFuture<Connection> |
Endpoint.getConnection(URI destination)
Deprecated.
|
default IoFuture<Connection> |
Endpoint.getConnection(URI destination,
SSLContext sslContext,
AuthenticationConfiguration authenticationConfiguration)
Deprecated.
|
default IoFuture<Connection> |
Endpoint.getConnection(URI destination,
SSLContext sslContext,
AuthenticationConfiguration connectionConfiguration,
AuthenticationConfiguration operateConfiguration)
Deprecated.
|
default IoFuture<Connection> |
Endpoint.getConnection(URI destination,
String abstractType,
String abstractTypeAuthority)
Deprecated.
|
default IoFuture<Connection> |
Endpoint.getConnectionIfExists(URI destination)
Deprecated.
|
default IoFuture<Connection> |
Endpoint.getConnectionIfExists(URI destination,
SSLContext sslContext,
AuthenticationConfiguration connectionConfiguration,
AuthenticationConfiguration operateConfiguration)
Deprecated.
|
default IoFuture<Connection> |
Endpoint.getConnectionIfExists(URI destination,
String abstractType,
String abstractTypeAuthority)
Deprecated.
|
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 |
---|---|
IoFuture<ConnectionPeerIdentity> |
RemoteNamingProvider.getFuturePeerIdentity(URI location)
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> |
XnioIoFactory.acceptMessageConnection(SocketAddress destination,
ChannelListener<? super MessageConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Accept a message connection at a destination address.
|
IoFuture<MessageConnection> |
XnioIoThread.acceptMessageConnection(SocketAddress destination,
ChannelListener<? super MessageConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap) |
IoFuture<MessageConnection> |
XnioWorker.acceptMessageConnection(SocketAddress destination,
ChannelListener<? super MessageConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap) |
IoFuture<ConnectedStreamChannel> |
XnioWorker.acceptStream(SocketAddress destination,
ChannelListener<? super ConnectedStreamChannel> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Deprecated.
|
IoFuture<StreamConnection> |
XnioIoFactory.acceptStreamConnection(SocketAddress destination,
ChannelListener<? super StreamConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Accept a stream connection at a destination address.
|
IoFuture<StreamConnection> |
XnioIoThread.acceptStreamConnection(SocketAddress destination,
ChannelListener<? super StreamConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap) |
IoFuture<StreamConnection> |
XnioWorker.acceptStreamConnection(SocketAddress destination,
ChannelListener<? super StreamConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap) |
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> |
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) |
<A> IoFuture<T> |
FinishedIoFuture.addNotifier(IoFuture.Notifier<? super T,A> notifier,
A attachment) |
IoFuture<T> |
IoFuture.cancel()
Cancel an operation.
|
IoFuture<T> |
AbstractIoFuture.cancel()
Cancel an operation.
|
IoFuture<T> |
AbstractConvertingIoFuture.cancel() |
IoFuture<T> |
FailedIoFuture.cancel()
Cancel the operation.
|
IoFuture<T> |
FinishedIoFuture.cancel()
Cancel the operation.
|
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> |
XnioIoFactory.openMessageConnection(SocketAddress destination,
ChannelListener<? super MessageConnection> openListener,
OptionMap optionMap)
Connect to a remote message server.
|
IoFuture<MessageConnection> |
XnioIoThread.openMessageConnection(SocketAddress destination,
ChannelListener<? super MessageConnection> openListener,
OptionMap optionMap) |
IoFuture<MessageConnection> |
XnioWorker.openMessageConnection(SocketAddress destination,
ChannelListener<? super MessageConnection> openListener,
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> |
XnioIoThread.openStreamConnection(SocketAddress destination,
ChannelListener<? super StreamConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap) |
IoFuture<StreamConnection> |
XnioWorker.openStreamConnection(SocketAddress destination,
ChannelListener<? super StreamConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap) |
IoFuture<StreamConnection> |
XnioIoFactory.openStreamConnection(SocketAddress destination,
ChannelListener<? super StreamConnection> openListener,
OptionMap optionMap)
Connect to a remote stream server.
|
IoFuture<StreamConnection> |
XnioIoThread.openStreamConnection(SocketAddress destination,
ChannelListener<? super StreamConnection> openListener,
OptionMap optionMap) |
IoFuture<StreamConnection> |
XnioWorker.openStreamConnection(SocketAddress destination,
ChannelListener<? super StreamConnection> openListener,
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.
|
IoFuture<StreamConnection> |
XnioIoThread.openStreamConnection(SocketAddress bindAddress,
SocketAddress destination,
ChannelListener<? super StreamConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap) |
IoFuture<StreamConnection> |
XnioWorker.openStreamConnection(SocketAddress bindAddress,
SocketAddress destination,
ChannelListener<? super StreamConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap) |
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 © 2020 JBoss by Red Hat. All rights reserved.