Package | Description |
---|---|
org.xnio |
The main API package for XNIO.
|
org.xnio.http | |
org.xnio.sasl |
Utility classes for using SASL mechanisms atop NIO or XNIO APIs.
|
org.xnio.ssl |
Utility classes for using and implementing SSL within XNIO providers.
|
Modifier and Type | Field and Description |
---|---|
static OptionMap |
OptionMap.EMPTY
The empty option map.
|
Modifier and Type | Field and Description |
---|---|
static Option<OptionMap> |
Options.SSL_RNG_OPTIONS
The configuration of a secure RNG for SSL usage.
|
Modifier and Type | Method and Description |
---|---|
static <T> OptionMap |
OptionMap.create(Option<T> option,
T value)
Create a single-valued option map.
|
static <T1,T2> OptionMap |
OptionMap.create(Option<T1> option1,
T1 value1,
Option<T2> option2,
T2 value2)
Create a two-valued option map.
|
OptionMap |
OptionMap.Builder.getMap()
Build a map that reflects the current state of this builder.
|
Modifier and Type | Method and Description |
---|---|
IoFuture<ConnectedMessageChannel> |
XnioWorker.acceptDatagram(java.net.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(java.net.SocketAddress destination,
ChannelListener<? super MessageConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap) |
IoFuture<MessageConnection> |
XnioIoThread.acceptMessageConnection(java.net.SocketAddress destination,
ChannelListener<? super MessageConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap) |
IoFuture<MessageConnection> |
XnioIoFactory.acceptMessageConnection(java.net.SocketAddress destination,
ChannelListener<? super MessageConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Accept a message connection at a destination address.
|
IoFuture<ConnectedStreamChannel> |
XnioWorker.acceptStream(java.net.SocketAddress destination,
ChannelListener<? super ConnectedStreamChannel> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Deprecated.
|
IoFuture<StreamConnection> |
XnioWorker.acceptStreamConnection(java.net.SocketAddress destination,
ChannelListener<? super StreamConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap) |
IoFuture<StreamConnection> |
XnioIoThread.acceptStreamConnection(java.net.SocketAddress destination,
ChannelListener<? super StreamConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap) |
IoFuture<StreamConnection> |
XnioIoFactory.acceptStreamConnection(java.net.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(java.net.InetSocketAddress destination,
ChannelListener<? super StreamConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Implementation helper method to accept a TCP connection.
|
OptionMap.Builder |
OptionMap.Builder.addAll(OptionMap optionMap)
Add all entries from an existing option map to the one being built.
|
IoFuture<ConnectedMessageChannel> |
XnioWorker.connectDatagram(java.net.SocketAddress destination,
ChannelListener<? super ConnectedMessageChannel> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Deprecated.
|
IoFuture<ConnectedMessageChannel> |
XnioWorker.connectDatagram(java.net.SocketAddress bindAddress,
java.net.SocketAddress destination,
ChannelListener<? super ConnectedMessageChannel> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Deprecated.
|
IoFuture<ConnectedStreamChannel> |
XnioWorker.connectStream(java.net.SocketAddress destination,
ChannelListener<? super ConnectedStreamChannel> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Deprecated.
|
IoFuture<ConnectedStreamChannel> |
XnioWorker.connectStream(java.net.SocketAddress destination,
ChannelListener<? super ConnectedStreamChannel> openListener,
OptionMap optionMap)
Deprecated.
|
IoFuture<ConnectedStreamChannel> |
XnioWorker.connectStream(java.net.SocketAddress bindAddress,
java.net.SocketAddress destination,
ChannelListener<? super ConnectedStreamChannel> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Deprecated.
|
FileSystemWatcher |
Xnio.createFileSystemWatcher(java.lang.String name,
OptionMap options)
Creates a file system watcher, that can be used to monitor file system changes.
|
protected AcceptingChannel<StreamConnection> |
XnioWorker.createLocalStreamConnectionServer(LocalSocketAddress bindAddress,
ChannelListener<? super AcceptingChannel<StreamConnection>> acceptListener,
OptionMap optionMap)
Implementation helper method to create a UNIX domain stream server.
|
void |
XnioWorker.createOneWayPipe(ChannelListener<? super StreamSourceChannel> sourceListener,
ChannelListener<? super StreamSinkChannel> sinkListener,
OptionMap optionMap)
Deprecated.
Users should prefer the simpler
XnioWorker.createHalfDuplexPipe() instead. |
void |
XnioWorker.createPipe(ChannelListener<? super StreamChannel> leftOpenListener,
ChannelListener<? super StreamChannel> rightOpenListener,
OptionMap optionMap)
Deprecated.
Users should prefer the simpler
XnioWorker.createFullDuplexPipe() instead. |
AcceptingChannel<StreamConnection> |
XnioWorker.createStreamConnectionServer(java.net.SocketAddress bindAddress,
ChannelListener<? super AcceptingChannel<StreamConnection>> acceptListener,
OptionMap optionMap)
Create a stream server, for TCP or UNIX domain servers.
|
AcceptingChannel<? extends ConnectedStreamChannel> |
XnioWorker.createStreamServer(java.net.SocketAddress bindAddress,
ChannelListener<? super AcceptingChannel<ConnectedStreamChannel>> acceptListener,
OptionMap optionMap)
Deprecated.
|
protected AcceptingChannel<StreamConnection> |
XnioWorker.createTcpConnectionServer(java.net.InetSocketAddress bindAddress,
ChannelListener<? super AcceptingChannel<StreamConnection>> acceptListener,
OptionMap optionMap)
Implementation helper method to create a TCP stream server.
|
MulticastMessageChannel |
XnioWorker.createUdpServer(java.net.InetSocketAddress bindAddress,
ChannelListener<? super MulticastMessageChannel> bindListener,
OptionMap optionMap)
Create a UDP server.
|
MulticastMessageChannel |
XnioWorker.createUdpServer(java.net.InetSocketAddress bindAddress,
OptionMap optionMap)
Create a UDP server.
|
XnioWorker |
Xnio.createWorker(OptionMap optionMap)
Construct a new XNIO worker.
|
XnioWorker |
Xnio.createWorker(java.lang.ThreadGroup threadGroup,
OptionMap optionMap)
Construct a new XNIO worker.
|
abstract XnioWorker |
Xnio.createWorker(java.lang.ThreadGroup threadGroup,
OptionMap optionMap,
java.lang.Runnable terminationTask)
Construct a new XNIO worker.
|
boolean |
OptionMap.equals(OptionMap other)
Determine whether this option map is equal to another.
|
StreamSinkChannel |
XnioWorker.getDeflatingChannel(StreamSinkChannel delegate,
OptionMap options)
Create a stream channel that compresses to the destination according to the configuration in the given option map.
|
StreamSourceChannel |
XnioWorker.getInflatingChannel(StreamSourceChannel delegate,
OptionMap options)
Create a stream channel that decompresses the source data according to the configuration in the given option map.
|
XnioSsl |
Xnio.getSslProvider(javax.net.ssl.KeyManager[] keyManagers,
javax.net.ssl.TrustManager[] trustManagers,
OptionMap optionMap)
Get an SSL provider for this XNIO provider.
|
XnioSsl |
Xnio.getSslProvider(OptionMap optionMap)
Get an SSL provider for this XNIO provider.
|
FileChannel |
Xnio.openFile(java.io.File file,
OptionMap options)
Open a file on the filesystem.
|
FileChannel |
Xnio.openFile(java.lang.String fileName,
OptionMap options)
Open a file on the filesystem.
|
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(java.net.SocketAddress destination,
ChannelListener<? super MessageConnection> openListener,
OptionMap optionMap) |
IoFuture<MessageConnection> |
XnioIoThread.openMessageConnection(java.net.SocketAddress destination,
ChannelListener<? super MessageConnection> openListener,
OptionMap optionMap) |
IoFuture<MessageConnection> |
XnioIoFactory.openMessageConnection(java.net.SocketAddress destination,
ChannelListener<? super MessageConnection> openListener,
OptionMap optionMap)
Connect to a remote message server.
|
IoFuture<StreamConnection> |
XnioWorker.openStreamConnection(java.net.SocketAddress destination,
ChannelListener<? super StreamConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap) |
IoFuture<StreamConnection> |
XnioIoThread.openStreamConnection(java.net.SocketAddress destination,
ChannelListener<? super StreamConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap) |
IoFuture<StreamConnection> |
XnioIoFactory.openStreamConnection(java.net.SocketAddress destination,
ChannelListener<? super StreamConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Connect to a remote stream server.
|
IoFuture<StreamConnection> |
XnioWorker.openStreamConnection(java.net.SocketAddress destination,
ChannelListener<? super StreamConnection> openListener,
OptionMap optionMap) |
IoFuture<StreamConnection> |
XnioIoThread.openStreamConnection(java.net.SocketAddress destination,
ChannelListener<? super StreamConnection> openListener,
OptionMap optionMap) |
IoFuture<StreamConnection> |
XnioIoFactory.openStreamConnection(java.net.SocketAddress destination,
ChannelListener<? super StreamConnection> openListener,
OptionMap optionMap)
Connect to a remote stream server.
|
IoFuture<StreamConnection> |
XnioWorker.openStreamConnection(java.net.SocketAddress bindAddress,
java.net.SocketAddress destination,
ChannelListener<? super StreamConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap) |
IoFuture<StreamConnection> |
XnioIoThread.openStreamConnection(java.net.SocketAddress bindAddress,
java.net.SocketAddress destination,
ChannelListener<? super StreamConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap) |
IoFuture<StreamConnection> |
XnioIoFactory.openStreamConnection(java.net.SocketAddress bindAddress,
java.net.SocketAddress destination,
ChannelListener<? super StreamConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Connect to a remote stream server.
|
protected IoFuture<StreamConnection> |
XnioIoThread.openTcpStreamConnection(java.net.InetSocketAddress bindAddress,
java.net.InetSocketAddress destinationAddress,
ChannelListener<? super StreamConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Implementation helper method to connect to a TCP server.
|
Constructor and Description |
---|
XnioWorker(Xnio xnio,
java.lang.ThreadGroup threadGroup,
OptionMap optionMap,
java.lang.Runnable terminationTask)
Construct a new instance.
|
Modifier and Type | Method and Description |
---|---|
static IoFuture<StreamConnection> |
HttpUpgrade.performUpgrade(XnioWorker worker,
java.net.InetSocketAddress bindAddress,
java.net.URI uri,
java.util.Map<java.lang.String,java.util.List<java.lang.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,
java.net.InetSocketAddress bindAddress,
java.net.URI uri,
java.util.Map<java.lang.String,java.lang.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,
java.net.InetSocketAddress bindAddress,
java.net.URI uri,
java.util.Map<java.lang.String,java.util.List<java.lang.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,
java.net.InetSocketAddress bindAddress,
java.net.URI uri,
java.util.Map<java.lang.String,java.lang.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.
|
Modifier and Type | Method and Description |
---|---|
static java.util.Map<java.lang.String,java.lang.Object> |
SaslUtils.createPropertyMap(OptionMap optionMap,
boolean secure)
Create a SASL property map from an XNIO option map.
|
Modifier and Type | Method and Description |
---|---|
IoFuture<ConnectedSslStreamChannel> |
XnioSsl.connectSsl(XnioWorker worker,
java.net.InetSocketAddress destination,
ChannelListener<? super ConnectedSslStreamChannel> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Deprecated.
|
IoFuture<ConnectedSslStreamChannel> |
XnioSsl.connectSsl(XnioWorker worker,
java.net.InetSocketAddress destination,
ChannelListener<? super ConnectedSslStreamChannel> openListener,
OptionMap optionMap)
Deprecated.
|
abstract IoFuture<ConnectedSslStreamChannel> |
XnioSsl.connectSsl(XnioWorker worker,
java.net.InetSocketAddress bindAddress,
java.net.InetSocketAddress destination,
ChannelListener<? super ConnectedSslStreamChannel> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Deprecated.
|
IoFuture<ConnectedSslStreamChannel> |
JsseXnioSsl.connectSsl(XnioWorker worker,
java.net.InetSocketAddress bindAddress,
java.net.InetSocketAddress destination,
ChannelListener<? super ConnectedSslStreamChannel> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap) |
IoFuture<ConnectedSslStreamChannel> |
XnioSsl.connectSsl(XnioWorker worker,
java.net.InetSocketAddress bindAddress,
java.net.InetSocketAddress destination,
ChannelListener<? super ConnectedSslStreamChannel> openListener,
OptionMap optionMap)
Deprecated.
|
abstract AcceptingChannel<SslConnection> |
XnioSsl.createSslConnectionServer(XnioWorker worker,
java.net.InetSocketAddress bindAddress,
ChannelListener<? super AcceptingChannel<SslConnection>> acceptListener,
OptionMap optionMap)
Create a bound TCP SSL server.
|
AcceptingChannel<SslConnection> |
JsseXnioSsl.createSslConnectionServer(XnioWorker worker,
java.net.InetSocketAddress bindAddress,
ChannelListener<? super AcceptingChannel<SslConnection>> acceptListener,
OptionMap optionMap) |
static javax.net.ssl.SSLContext |
JsseSslUtils.createSSLContext(javax.net.ssl.KeyManager[] keyManagers,
javax.net.ssl.TrustManager[] trustManagers,
java.security.SecureRandom secureRandom,
OptionMap optionMap)
Create a new SSL context, configured from an option map and the given parameters.
|
static javax.net.ssl.SSLContext |
JsseSslUtils.createSSLContext(OptionMap optionMap)
Create a new SSL context, configured from an option map.
|
static javax.net.ssl.SSLEngine |
JsseSslUtils.createSSLEngine(javax.net.ssl.SSLContext sslContext,
OptionMap optionMap,
java.net.InetSocketAddress peerAddress)
Create a new client mode SSL engine, configured from an option map.
|
abstract AcceptingChannel<ConnectedSslStreamChannel> |
XnioSsl.createSslTcpServer(XnioWorker worker,
java.net.InetSocketAddress bindAddress,
ChannelListener<? super AcceptingChannel<ConnectedSslStreamChannel>> acceptListener,
OptionMap optionMap)
Deprecated.
|
AcceptingChannel<ConnectedSslStreamChannel> |
JsseXnioSsl.createSslTcpServer(XnioWorker worker,
java.net.InetSocketAddress bindAddress,
ChannelListener<? super AcceptingChannel<ConnectedSslStreamChannel>> acceptListener,
OptionMap optionMap) |
IoFuture<SslConnection> |
XnioSsl.openSslConnection(XnioIoThread ioThread,
java.net.InetSocketAddress destination,
ChannelListener<? super SslConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Create an SSL connection to a remote host.
|
IoFuture<SslConnection> |
XnioSsl.openSslConnection(XnioIoThread ioThread,
java.net.InetSocketAddress destination,
ChannelListener<? super SslConnection> openListener,
OptionMap optionMap)
Create an SSL connection to a remote host.
|
abstract IoFuture<SslConnection> |
XnioSsl.openSslConnection(XnioIoThread ioThread,
java.net.InetSocketAddress bindAddress,
java.net.InetSocketAddress destination,
ChannelListener<? super SslConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Create an SSL connection to a remote host.
|
IoFuture<SslConnection> |
JsseXnioSsl.openSslConnection(XnioIoThread ioThread,
java.net.InetSocketAddress bindAddress,
java.net.InetSocketAddress destination,
ChannelListener<? super SslConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap) |
IoFuture<SslConnection> |
XnioSsl.openSslConnection(XnioIoThread ioThread,
java.net.InetSocketAddress bindAddress,
java.net.InetSocketAddress destination,
ChannelListener<? super SslConnection> openListener,
OptionMap optionMap)
Create an SSL connection to a remote host.
|
IoFuture<SslConnection> |
XnioSsl.openSslConnection(XnioWorker worker,
java.net.InetSocketAddress destination,
ChannelListener<? super SslConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Create an SSL connection to a remote host.
|
IoFuture<SslConnection> |
XnioSsl.openSslConnection(XnioWorker worker,
java.net.InetSocketAddress destination,
ChannelListener<? super SslConnection> openListener,
OptionMap optionMap)
Create an SSL connection to a remote host.
|
abstract IoFuture<SslConnection> |
XnioSsl.openSslConnection(XnioWorker worker,
java.net.InetSocketAddress bindAddress,
java.net.InetSocketAddress destination,
ChannelListener<? super SslConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Create an SSL connection to a remote host.
|
IoFuture<SslConnection> |
JsseXnioSsl.openSslConnection(XnioWorker worker,
java.net.InetSocketAddress bindAddress,
java.net.InetSocketAddress destination,
ChannelListener<? super SslConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap) |
IoFuture<SslConnection> |
XnioSsl.openSslConnection(XnioWorker worker,
java.net.InetSocketAddress bindAddress,
java.net.InetSocketAddress destination,
ChannelListener<? super SslConnection> openListener,
OptionMap optionMap)
Create an SSL connection to a remote host.
|
Constructor and Description |
---|
JsseXnioSsl(Xnio xnio,
OptionMap optionMap)
Construct a new instance.
|
JsseXnioSsl(Xnio xnio,
OptionMap optionMap,
javax.net.ssl.SSLContext sslContext)
Construct a new instance.
|
XnioSsl(Xnio xnio,
javax.net.ssl.SSLContext sslContext,
OptionMap optionMap)
Construct a new instance.
|
Copyright © 2016 JBoss, a division of Red Hat, Inc.