Modifier and Type | Method and Description |
---|---|
Undertow.ListenerBuilder |
Undertow.ListenerBuilder.setOverrideSocketOptions(OptionMap overrideSocketOptions) |
void |
Undertow.ListenerInfo.setServerOptions(OptionMap options) |
Modifier and Type | Method and Description |
---|---|
void |
AjpClientProvider.connect(ClientCallback<ClientConnection> listener,
InetSocketAddress bindAddress,
URI uri,
XnioIoThread ioThread,
XnioSsl ssl,
ByteBufferPool bufferPool,
OptionMap options) |
void |
AjpClientProvider.connect(ClientCallback<ClientConnection> listener,
InetSocketAddress bindAddress,
URI uri,
XnioWorker worker,
XnioSsl ssl,
ByteBufferPool bufferPool,
OptionMap options) |
void |
AjpClientProvider.connect(ClientCallback<ClientConnection> listener,
URI uri,
XnioIoThread ioThread,
XnioSsl ssl,
ByteBufferPool bufferPool,
OptionMap options) |
void |
AjpClientProvider.connect(ClientCallback<ClientConnection> listener,
URI uri,
XnioWorker worker,
XnioSsl ssl,
ByteBufferPool bufferPool,
OptionMap options) |
Modifier and Type | Method and Description |
---|---|
void |
HttpClientProvider.connect(ClientCallback<ClientConnection> listener,
InetSocketAddress bindAddress,
URI uri,
XnioIoThread ioThread,
XnioSsl ssl,
ByteBufferPool bufferPool,
OptionMap options) |
void |
HttpClientProvider.connect(ClientCallback<ClientConnection> listener,
InetSocketAddress bindAddress,
URI uri,
XnioWorker worker,
XnioSsl ssl,
ByteBufferPool bufferPool,
OptionMap options) |
void |
HttpClientProvider.connect(ClientCallback<ClientConnection> listener,
URI uri,
XnioIoThread ioThread,
XnioSsl ssl,
ByteBufferPool bufferPool,
OptionMap options) |
void |
HttpClientProvider.connect(ClientCallback<ClientConnection> listener,
URI uri,
XnioWorker worker,
XnioSsl ssl,
ByteBufferPool bufferPool,
OptionMap options) |
Modifier and Type | Method and Description |
---|---|
static ALPNClientSelector.ALPNProtocol |
Http2ClientProvider.alpnProtocol(ClientCallback<ClientConnection> listener,
URI uri,
ByteBufferPool bufferPool,
OptionMap options) |
void |
Http2PriorKnowledgeClientProvider.connect(ClientCallback<ClientConnection> listener,
InetSocketAddress bindAddress,
URI uri,
XnioIoThread ioThread,
XnioSsl ssl,
ByteBufferPool bufferPool,
OptionMap options) |
void |
Http2ClientProvider.connect(ClientCallback<ClientConnection> listener,
InetSocketAddress bindAddress,
URI uri,
XnioIoThread ioThread,
XnioSsl ssl,
ByteBufferPool bufferPool,
OptionMap options) |
void |
Http2ClearClientProvider.connect(ClientCallback<ClientConnection> listener,
InetSocketAddress bindAddress,
URI uri,
XnioIoThread ioThread,
XnioSsl ssl,
ByteBufferPool bufferPool,
OptionMap options) |
void |
Http2PriorKnowledgeClientProvider.connect(ClientCallback<ClientConnection> listener,
InetSocketAddress bindAddress,
URI uri,
XnioWorker worker,
XnioSsl ssl,
ByteBufferPool bufferPool,
OptionMap options) |
void |
Http2ClientProvider.connect(ClientCallback<ClientConnection> listener,
InetSocketAddress bindAddress,
URI uri,
XnioWorker worker,
XnioSsl ssl,
ByteBufferPool bufferPool,
OptionMap options) |
void |
Http2ClearClientProvider.connect(ClientCallback<ClientConnection> listener,
InetSocketAddress bindAddress,
URI uri,
XnioWorker worker,
XnioSsl ssl,
ByteBufferPool bufferPool,
OptionMap options) |
void |
Http2PriorKnowledgeClientProvider.connect(ClientCallback<ClientConnection> listener,
URI uri,
XnioIoThread ioThread,
XnioSsl ssl,
ByteBufferPool bufferPool,
OptionMap options) |
void |
Http2ClientProvider.connect(ClientCallback<ClientConnection> listener,
URI uri,
XnioIoThread ioThread,
XnioSsl ssl,
ByteBufferPool bufferPool,
OptionMap options) |
void |
Http2ClearClientProvider.connect(ClientCallback<ClientConnection> listener,
URI uri,
XnioIoThread ioThread,
XnioSsl ssl,
ByteBufferPool bufferPool,
OptionMap options) |
void |
Http2PriorKnowledgeClientProvider.connect(ClientCallback<ClientConnection> listener,
URI uri,
XnioWorker worker,
XnioSsl ssl,
ByteBufferPool bufferPool,
OptionMap options) |
void |
Http2ClientProvider.connect(ClientCallback<ClientConnection> listener,
URI uri,
XnioWorker worker,
XnioSsl ssl,
ByteBufferPool bufferPool,
OptionMap options) |
void |
Http2ClearClientProvider.connect(ClientCallback<ClientConnection> listener,
URI uri,
XnioWorker worker,
XnioSsl ssl,
ByteBufferPool bufferPool,
OptionMap options) |
static String |
Http2ClearClientProvider.createSettingsFrame(OptionMap options,
ByteBufferPool bufferPool) |
Modifier and Type | Method and Description |
---|---|
protected OptionMap |
AjpClientChannel.getSettings() |
Constructor and Description |
---|
AjpClientChannel(StreamConnection connectedStreamChannel,
ByteBufferPool bufferPool,
OptionMap settings)
Create a new
AbstractFramedChannel
8 |
Constructor and Description |
---|
Http2Channel(StreamConnection connectedStreamChannel,
String protocol,
ByteBufferPool bufferPool,
PooledByteBuffer data,
boolean clientSide,
boolean fromUpgrade,
boolean prefaceRequired,
ByteBuffer initialOtherSideSettings,
OptionMap settings) |
Http2Channel(StreamConnection connectedStreamChannel,
String protocol,
ByteBufferPool bufferPool,
PooledByteBuffer data,
boolean clientSide,
boolean fromUpgrade,
boolean prefaceRequired,
OptionMap settings) |
Http2Channel(StreamConnection connectedStreamChannel,
String protocol,
ByteBufferPool bufferPool,
PooledByteBuffer data,
boolean clientSide,
boolean fromUpgrade,
OptionMap settings) |
Constructor and Description |
---|
UndertowXnioSsl(Xnio xnio,
OptionMap optionMap)
Construct a new instance.
|
UndertowXnioSsl(Xnio xnio,
OptionMap optionMap,
ByteBufferPool bufferPool)
Construct a new instance.
|
UndertowXnioSsl(Xnio xnio,
OptionMap optionMap,
ByteBufferPool bufferPool,
SSLContext sslContext)
Construct a new instance.
|
UndertowXnioSsl(Xnio xnio,
OptionMap optionMap,
SSLContext sslContext)
Construct a new instance.
|
Modifier and Type | Field and Description |
---|---|
protected OptionMap |
AbstractServerConnection.undertowOptions |
Modifier and Type | Method and Description |
---|---|
abstract OptionMap |
ServerConnection.getUndertowOptions() |
OptionMap |
OpenListener.getUndertowOptions() |
OptionMap |
AbstractServerConnection.getUndertowOptions() |
Modifier and Type | Method and Description |
---|---|
void |
OpenListener.setUndertowOptions(OptionMap undertowOptions) |
Constructor and Description |
---|
AbstractServerConnection(StreamConnection channel,
ByteBufferPool bufferPool,
HttpHandler rootHandler,
OptionMap undertowOptions,
int bufferSize) |
Modifier and Type | Method and Description |
---|---|
LoadBalancingProxyClient |
LoadBalancingProxyClient.addHost(InetSocketAddress bindAddress,
URI host,
String jvmRoute,
XnioSsl ssl,
OptionMap options) |
LoadBalancingProxyClient |
LoadBalancingProxyClient.addHost(URI host,
String jvmRoute,
XnioSsl ssl,
OptionMap options) |
Constructor and Description |
---|
ProxyConnectionPool(ConnectionPoolManager connectionPoolManager,
InetSocketAddress bindAddress,
URI uri,
UndertowClient client,
OptionMap options) |
ProxyConnectionPool(ConnectionPoolManager connectionPoolManager,
InetSocketAddress bindAddress,
URI uri,
XnioSsl ssl,
UndertowClient client,
OptionMap options) |
ProxyConnectionPool(ConnectionPoolManager connectionPoolManager,
URI uri,
UndertowClient client,
OptionMap options) |
ProxyConnectionPool(ConnectionPoolManager connectionPoolManager,
URI uri,
XnioSsl ssl,
UndertowClient client,
OptionMap options) |
Modifier and Type | Method and Description |
---|---|
ModCluster.Builder |
ModCluster.Builder.setClientOptions(OptionMap clientOptions) |
Modifier and Type | Method and Description |
---|---|
OptionMap |
AjpOpenListener.getUndertowOptions() |
Modifier and Type | Method and Description |
---|---|
void |
AjpOpenListener.setUndertowOptions(OptionMap undertowOptions) |
Constructor and Description |
---|
AjpOpenListener(ByteBufferPool pool,
OptionMap undertowOptions) |
AjpOpenListener(Pool<ByteBuffer> pool,
OptionMap undertowOptions) |
AjpServerConnection(StreamConnection channel,
ByteBufferPool bufferPool,
HttpHandler rootHandler,
OptionMap undertowOptions,
int bufferSize) |
Modifier and Type | Method and Description |
---|---|
protected OptionMap |
AbstractFramedChannel.getSettings() |
Constructor and Description |
---|
AbstractFramedChannel(StreamConnection connectedStreamChannel,
ByteBufferPool bufferPool,
FramePriority<C,R,S> framePriority,
PooledByteBuffer readData,
OptionMap settings)
Create a new
AbstractFramedChannel
8 |
Modifier and Type | Method and Description |
---|---|
OptionMap |
HttpOpenListener.getUndertowOptions() |
OptionMap |
AlpnOpenListener.getUndertowOptions() |
Modifier and Type | Method and Description |
---|---|
static HttpRequestParser |
HttpRequestParser.instance(OptionMap options) |
void |
HttpOpenListener.setUndertowOptions(OptionMap undertowOptions) |
void |
AlpnOpenListener.setUndertowOptions(OptionMap undertowOptions) |
Modifier and Type | Method and Description |
---|---|
OptionMap |
Http2ServerConnection.getUndertowOptions() |
OptionMap |
Http2OpenListener.getUndertowOptions() |
Modifier and Type | Method and Description |
---|---|
void |
Http2OpenListener.setUndertowOptions(OptionMap undertowOptions) |
Constructor and Description |
---|
Http2OpenListener(ByteBufferPool pool,
OptionMap undertowOptions) |
Http2OpenListener(ByteBufferPool pool,
OptionMap undertowOptions,
String protocol) |
Http2OpenListener(Pool<ByteBuffer> pool,
OptionMap undertowOptions)
Deprecated.
|
Http2OpenListener(Pool<ByteBuffer> pool,
OptionMap undertowOptions,
String protocol)
Deprecated.
|
Http2ReceiveListener(HttpHandler rootHandler,
OptionMap undertowOptions,
int bufferSize,
ConnectorStatisticsImpl connectorStatistics) |
Http2ServerConnection(Http2Channel channel,
Http2DataStreamSinkChannel sinkChannel,
OptionMap undertowOptions,
int bufferSize,
HttpHandler rootHandler)
Channel that is used when the request is already half closed
|
Http2ServerConnection(Http2Channel channel,
Http2StreamSourceChannel requestChannel,
OptionMap undertowOptions,
int bufferSize,
HttpHandler rootHandler) |
Constructor and Description |
---|
ProxyProtocolOpenListener(OpenListener openListener,
UndertowXnioSsl ssl,
ByteBufferPool bufferPool,
OptionMap sslOptionMap) |
Modifier and Type | Method and Description |
---|---|
OptionMap |
ServletWebSocketHttpExchange.getOptions() |
Modifier and Type | Method and Description |
---|---|
OptionMap |
WebSocketClient.ConnectionBuilder.getOptionMap() |
Modifier and Type | Method and Description |
---|---|
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.
|
abstract WebSocketChannel |
WebSocketClientHandshake.createChannel(StreamConnection channel,
String wsUri,
ByteBufferPool bufferPool,
OptionMap options) |
WebSocketChannel |
WebSocket13ClientHandshake.createChannel(StreamConnection channel,
String wsUri,
ByteBufferPool bufferPool,
OptionMap options) |
WebSocketClient.ConnectionBuilder |
WebSocketClient.ConnectionBuilder.setOptionMap(OptionMap optionMap) |
Constructor and Description |
---|
WebSocketChannel(StreamConnection connectedStreamChannel,
ByteBufferPool bufferPool,
WebSocketVersion version,
String wsUrl,
String subProtocol,
boolean client,
boolean extensionsSupported,
ExtensionFunction extensionFunction,
Set<WebSocketChannel> peerConnections,
OptionMap options)
Create a new
WebSocketChannel
8 |
Constructor and Description |
---|
WebSocket07Channel(StreamConnection channel,
ByteBufferPool bufferPool,
String wsUrl,
String subProtocol,
boolean client,
boolean allowExtensions,
ExtensionFunction extensionFunction,
Set<WebSocketChannel> openConnections,
OptionMap options)
Create a new
WebSocket07Channel |
Constructor and Description |
---|
WebSocket08Channel(StreamConnection channel,
ByteBufferPool bufferPool,
String wsUrl,
String subProtocols,
boolean client,
boolean allowExtensions,
ExtensionFunction extensionFunction,
Set<WebSocketChannel> openConnections,
OptionMap options) |
Constructor and Description |
---|
WebSocket13Channel(StreamConnection channel,
ByteBufferPool bufferPool,
String wsUrl,
String subProtocols,
boolean client,
boolean allowExtensions,
ExtensionFunction extensionFunction,
Set<WebSocketChannel> openConnections,
OptionMap options) |
Modifier and Type | Method and Description |
---|---|
OptionMap |
WebSocketHttpExchange.getOptions() |
OptionMap |
AsyncWebSocketHttpServerExchange.getOptions() |
Modifier and Type | Method and Description |
---|---|
OptionMap |
JBossEJBProperties.getEndpointCreationOptions() |
OptionMap |
JBossEJBProperties.getRemoteConnectionProviderCreationOptions() |
Modifier and Type | Method and Description |
---|---|
Registration |
LegacyEndpoint.addConnectionProvider(String uriScheme,
ConnectionProviderFactory providerFactory,
OptionMap optionMap)
Deprecated.
|
Registration |
Endpoint.addConnectionProvider(String uriScheme,
ConnectionProviderFactory providerFactory,
OptionMap optionMap)
Register a connection provider for a URI scheme.
|
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.
|
static Endpoint |
Remoting.createEndpoint(OptionMap optionMap)
Deprecated.
Create an anonymous endpoint.
|
static Endpoint |
Remoting.createEndpoint(String endpointName,
OptionMap optionMap)
Deprecated.
Create a new endpoint with the given configuration.
|
static Endpoint |
Remoting.createEndpoint(String endpointName,
Xnio xnio,
OptionMap optionMap)
Deprecated.
Create an endpoint with the given configuration which manages its own worker.
|
static Endpoint |
Remoting.createEndpoint(String endpointName,
XnioWorker xnioWorker,
OptionMap optionMap)
Deprecated.
Create an endpoint with the given configuration and existing worker.
|
IoFuture<T> |
ClientServiceHandle.getClientService(Connection connection,
OptionMap optionMap)
Get or establish the future client service for the given connection.
|
static AuthenticationConfiguration |
RemotingOptions.mergeOptionsIntoAuthenticationConfiguration(OptionMap optionMap,
AuthenticationConfiguration authenticationConfiguration)
Merge the given option map into the given authentication configuration, and return the result.
|
IoFuture<Channel> |
Connection.openChannel(String serviceType,
OptionMap optionMap)
Open a channel to a remote service on this connection.
|
Registration |
LegacyEndpoint.registerService(String serviceType,
OpenListener openListener,
OptionMap optionMap)
Deprecated.
|
Registration |
Endpoint.registerService(String serviceType,
OpenListener openListener,
OptionMap optionMap)
Register a new service.
|
Modifier and Type | Method and Description |
---|---|
ConnectionProvider |
RemoteConnectionProviderFactory.createInstance(ConnectionProviderContext context,
OptionMap optionMap,
String protocolName)
Create a provider instance for an endpoint.
|
ConnectionProvider |
HttpUpgradeConnectionProviderFactory.createInstance(ConnectionProviderContext context,
OptionMap optionMap,
String protocolName)
Create a provider instance for an endpoint.
|
Modifier and Type | Method and Description |
---|---|
OptionMap |
RegisteredService.getOptionMap()
Get the service option map.
|
Modifier and Type | Method and Description |
---|---|
Cancellable |
ConnectionProvider.connect(URI destination,
SocketAddress bindAddress,
OptionMap connectOptions,
Result<ConnectionHandlerFactory> result,
AuthenticationConfiguration authenticationConfiguration,
SSLContext sslContext,
UnaryOperator<SaslClientFactory> saslClientFactoryOperator,
Collection<String> serverMechs)
Open an outbound connection, using the (optionally) given socket addresses as source and destination.
|
Consumer<StreamConnection> |
ExternalConnectionProvider.createConnectionAdaptor(OptionMap optionMap,
SaslAuthenticationFactory saslAuthenticationFactory)
Create a network server.
|
ConnectionProvider |
ConnectionProviderFactory.createInstance(ConnectionProviderContext context,
OptionMap optionMap,
String protocolName)
Create a provider instance for an endpoint.
|
AcceptingChannel<StreamConnection> |
NetworkServerProvider.createServer(SocketAddress bindAddress,
OptionMap optionMap,
SaslAuthenticationFactory saslAuthenticationFactory,
SSLContext sslContext)
Create a network server.
|
Cancellable |
ConnectionHandler.open(String serviceType,
Result<Channel> result,
OptionMap optionMap)
Open a request handler.
|
Constructor and Description |
---|
HttpConnectionPool(int maxConnections,
int maxStreamsPerConnection,
XnioWorker worker,
ByteBufferPool byteBufferPool,
OptionMap options,
HostPool hostPool,
long connectionIdleTimeout) |
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(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.
|
OptionMap.Builder |
OptionMap.Builder.addAll(OptionMap optionMap)
Add all entries from an existing option map to the one being built.
|
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.
|
FileSystemWatcher |
Xnio.createFileSystemWatcher(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(SocketAddress bindAddress,
ChannelListener<? super AcceptingChannel<StreamConnection>> acceptListener,
OptionMap optionMap)
Create a stream server, for TCP or UNIX domain servers.
|
AcceptingChannel<? extends ConnectedStreamChannel> |
XnioWorker.createStreamServer(SocketAddress bindAddress,
ChannelListener<? super AcceptingChannel<ConnectedStreamChannel>> acceptListener,
OptionMap optionMap)
Deprecated.
|
protected AcceptingChannel<StreamConnection> |
XnioWorker.createTcpConnectionServer(InetSocketAddress bindAddress,
ChannelListener<? super AcceptingChannel<StreamConnection>> acceptListener,
OptionMap optionMap)
Implementation helper method to create a TCP stream server.
|
MulticastMessageChannel |
XnioWorker.createUdpServer(InetSocketAddress bindAddress,
ChannelListener<? super MulticastMessageChannel> bindListener,
OptionMap optionMap)
Create a UDP server.
|
MulticastMessageChannel |
XnioWorker.createUdpServer(InetSocketAddress bindAddress,
OptionMap optionMap)
Create a UDP server.
|
XnioWorker |
Xnio.createWorker(OptionMap optionMap)
Construct a new XNIO worker.
|
XnioWorker |
Xnio.createWorker(ThreadGroup threadGroup,
OptionMap optionMap)
Construct a new XNIO worker.
|
XnioWorker |
Xnio.createWorker(ThreadGroup threadGroup,
OptionMap optionMap,
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(KeyManager[] keyManagers,
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(File file,
OptionMap options)
Open a file on the filesystem.
|
FileChannel |
Xnio.openFile(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(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.
|
XnioWorker.Builder |
XnioWorker.Builder.populateFromOptions(OptionMap optionMap) |
Modifier and Type | Method and Description |
---|---|
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.
|
Modifier and Type | Method and Description |
---|---|
static Map<String,Object> |
SaslUtils.createPropertyMap(OptionMap optionMap,
boolean secure)
Create a SASL property map from an XNIO option map.
|
Constructor and Description |
---|
JsseXnioSsl(Xnio xnio,
OptionMap optionMap)
Construct a new instance.
|
JsseXnioSsl(Xnio xnio,
OptionMap optionMap,
SSLContext sslContext)
Construct a new instance.
|
XnioSsl(Xnio xnio,
SSLContext sslContext,
OptionMap optionMap)
Construct a new instance.
|
Copyright © 2019 JBoss by Red Hat. All rights reserved.