Package | Description |
---|---|
org.jboss.ejb.client.remoting | |
org.jboss.naming.remote.protocol | |
org.jboss.naming.remote.protocol.v1 | |
org.jboss.remoting3 |
The base Remoting 3 API package.
|
org.xnio |
The main API package for XNIO.
|
org.xnio.channels | |
org.xnio.ssl |
Modifier and Type | Method and Description |
---|---|
static IoFuture<Connection> |
NetworkUtil.connect(Endpoint endpoint,
InetSocketAddress destination,
InetSocketAddress sourceBindAddress,
OptionMap connectionCreationOptions,
CallbackHandler callbackHandler,
SSLContext sslContext)
Deprecated.
Returns a
IoFuture to a Connection which is established to the destination host. |
static IoFuture<Connection> |
NetworkUtil.connect(Endpoint endpoint,
String destinationHost,
int destinationPort,
InetSocketAddress sourceBindAddress,
OptionMap connectionCreationOptions,
CallbackHandler callbackHandler,
SSLContext sslContext)
Deprecated.
Returns a
IoFuture to a Connection which is established to the destination host. |
Modifier and Type | Method and Description |
---|---|
static <V> Future<V> |
IoFutureHelper.future(IoFuture<V> ioFuture)
Deprecated.
|
static <V> V |
IoFutureHelper.get(IoFuture<V> ioFuture,
long timeout,
TimeUnit unit)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
static <V> Future<V> |
IoFutureHelper.future(IoFuture<V> ioFuture) |
static <V> V |
IoFutureHelper.get(IoFuture<V> ioFuture,
long timeout,
TimeUnit unit) |
Modifier and Type | Class and Description |
---|---|
class |
ProtocolIoFuture<T> |
Modifier and Type | Method and Description |
---|---|
IoFuture<Connection> |
Endpoint.connect(String protocol,
SocketAddress bindAddress,
SocketAddress destination)
Open a connection with a peer.
|
IoFuture<Connection> |
Endpoint.connect(String protocol,
SocketAddress bindAddress,
SocketAddress destination,
OptionMap connectOptions)
Open a connection with a peer.
|
IoFuture<Connection> |
Endpoint.connect(String protocol,
SocketAddress bindAddress,
SocketAddress destination,
OptionMap connectOptions,
CallbackHandler callbackHandler)
Open a connection with a peer.
|
IoFuture<Connection> |
Endpoint.connect(String protocol,
SocketAddress bindAddress,
SocketAddress destination,
OptionMap connectOptions,
CallbackHandler callbackHandler,
SSLContext sslContext)
Open a connection with a peer.
|
IoFuture<Connection> |
Endpoint.connect(String protocol,
SocketAddress bindAddress,
SocketAddress destination,
OptionMap connectOptions,
CallbackHandler callbackHandler,
XnioSsl xnioSsl)
Open a connection with a peer.
|
IoFuture<Connection> |
Endpoint.connect(String protocol,
SocketAddress bindAddress,
SocketAddress destination,
OptionMap connectOptions,
String userName,
String realmName,
char[] password)
Open a connection with a peer.
|
IoFuture<Connection> |
Endpoint.connect(String protocol,
SocketAddress bindAddress,
SocketAddress destination,
OptionMap connectOptions,
String userName,
String realmName,
char[] password,
SSLContext sslContext)
Open a connection with a peer.
|
IoFuture<Connection> |
Endpoint.connect(String protocol,
SocketAddress bindAddress,
SocketAddress destination,
OptionMap connectOptions,
String userName,
String realmName,
char[] password,
XnioSsl xnioSsl)
Open a connection with a peer.
|
IoFuture<Connection> |
Endpoint.connect(URI destination)
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,
CallbackHandler callbackHandler)
Open a connection with a peer.
|
IoFuture<Connection> |
Endpoint.connect(URI destination,
OptionMap connectOptions,
CallbackHandler callbackHandler,
SSLContext sslContext)
Open a connection with a peer.
|
IoFuture<Connection> |
Endpoint.connect(URI destination,
OptionMap connectOptions,
CallbackHandler callbackHandler,
XnioSsl xnioSsl)
Open a connection with a peer.
|
IoFuture<Connection> |
Endpoint.connect(URI destination,
OptionMap connectOptions,
String userName,
String realmName,
char[] password)
Open a connection with a peer.
|
IoFuture<Connection> |
Endpoint.connect(URI destination,
OptionMap connectOptions,
String userName,
String realmName,
char[] password,
SSLContext sslContext)
Open a connection with a peer.
|
IoFuture<Connection> |
Endpoint.connect(URI destination,
OptionMap connectOptions,
String userName,
String realmName,
char[] password,
XnioSsl xnioSsl)
Open a connection with a peer.
|
IoFuture<Channel> |
Connection.openChannel(String serviceType,
OptionMap optionMap)
Open a channel to a remote service on this connection.
|
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)
Accept a message connection at a destination address.
|
protected IoFuture<ConnectedMessageChannel> |
XnioWorker.acceptLocalDatagram(LocalSocketAddress destination,
ChannelListener<? super ConnectedMessageChannel> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Implementation helper method to accept a local (UNIX domain) datagram connection.
|
protected IoFuture<ConnectedStreamChannel> |
XnioWorker.acceptLocalStream(LocalSocketAddress destination,
ChannelListener<? super ConnectedStreamChannel> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Implementation helper method to accept a local (UNIX domain) stream connection.
|
IoFuture<ConnectedStreamChannel> |
XnioWorker.acceptStream(SocketAddress destination,
ChannelListener<? super ConnectedStreamChannel> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Accept a stream connection at a destination address.
|
protected IoFuture<ConnectedStreamChannel> |
XnioWorker.acceptTcpStream(InetSocketAddress destination,
ChannelListener<? super ConnectedStreamChannel> 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) |
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)
Connect to a remote stream server.
|
IoFuture<ConnectedMessageChannel> |
XnioWorker.connectDatagram(SocketAddress bindAddress,
SocketAddress destination,
ChannelListener<? super ConnectedMessageChannel> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Connect to a remote datagram server.
|
protected IoFuture<ConnectedMessageChannel> |
XnioWorker.connectLocalDatagram(LocalSocketAddress bindAddress,
LocalSocketAddress destination,
ChannelListener<? super ConnectedMessageChannel> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Implementation helper method to connect to a local (UNIX domain) datagram server.
|
protected IoFuture<ConnectedStreamChannel> |
XnioWorker.connectLocalStream(LocalSocketAddress bindAddress,
LocalSocketAddress destinationAddress,
ChannelListener<? super ConnectedStreamChannel> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Implementation helper method to connect to a local (UNIX domain) server.
|
IoFuture<ConnectedStreamChannel> |
XnioWorker.connectStream(SocketAddress destination,
ChannelListener<? super ConnectedStreamChannel> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Connect to a remote stream server.
|
IoFuture<ConnectedStreamChannel> |
XnioWorker.connectStream(SocketAddress destination,
ChannelListener<? super ConnectedStreamChannel> openListener,
OptionMap optionMap)
Connect to a remote stream server.
|
IoFuture<ConnectedStreamChannel> |
XnioWorker.connectStream(SocketAddress bindAddress,
SocketAddress destination,
ChannelListener<? super ConnectedStreamChannel> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Connect to a remote stream server.
|
protected IoFuture<ConnectedStreamChannel> |
XnioWorker.connectTcpStream(InetSocketAddress bindAddress,
InetSocketAddress destinationAddress,
ChannelListener<? super ConnectedStreamChannel> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Implementation helper method to connect to a TCP server.
|
protected IoFuture<ConnectedMessageChannel> |
XnioWorker.connectUdpDatagram(InetSocketAddress bindAddress,
InetSocketAddress destination,
ChannelListener<? super ConnectedMessageChannel> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Implementation helper method to connect to a UDP server.
|
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.
|
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 |
---|---|
IoFuture<? extends BoundChannel> |
BoundServerChannel.bind(SocketAddress address)
Add a binding.
|
Copyright © 2018 JBoss by Red Hat. All rights reserved.