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 |
---|---|
static ALPNClientSelector.ALPNProtocol |
SpdyClientProvider.alpnProtocol(ClientCallback<ClientConnection> listener,
URI uri,
ByteBufferPool bufferPool,
OptionMap options,
String protocol) |
void |
SpdyClientProvider.connect(ClientCallback<ClientConnection> listener,
InetSocketAddress bindAddress,
URI uri,
XnioIoThread ioThread,
XnioSsl ssl,
ByteBufferPool bufferPool,
OptionMap options) |
void |
SpdyClientProvider.connect(ClientCallback<ClientConnection> listener,
InetSocketAddress bindAddress,
URI uri,
XnioWorker worker,
XnioSsl ssl,
ByteBufferPool bufferPool,
OptionMap options) |
void |
SpdyClientProvider.connect(ClientCallback<ClientConnection> listener,
URI uri,
XnioIoThread ioThread,
XnioSsl ssl,
ByteBufferPool bufferPool,
OptionMap options) |
void |
SpdyClientProvider.connect(ClientCallback<ClientConnection> listener,
URI uri,
XnioWorker worker,
XnioSsl ssl,
ByteBufferPool bufferPool,
OptionMap options) |
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 |
---|
SpdyChannel(StreamConnection connectedStreamChannel,
ByteBufferPool bufferPool,
PooledByteBuffer data,
ByteBufferPool heapBufferPool,
boolean clientSide,
OptionMap options) |
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 | Field and Description |
---|---|
OptionMap |
ModCluster.Builder.clientOptions |
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 |
JDK9AlpnOpenListener.getUndertowOptions() |
OptionMap |
HttpOpenListener.getUndertowOptions() |
OptionMap |
AlpnOpenListener.getUndertowOptions() |
Modifier and Type | Method and Description |
---|---|
static HttpRequestParser |
HttpRequestParser.instance(OptionMap options) |
void |
JDK9AlpnOpenListener.setUndertowOptions(OptionMap undertowOptions) |
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) |
Modifier and Type | Method and Description |
---|---|
OptionMap |
SpdyServerConnection.getUndertowOptions() |
OptionMap |
SpdyPlainOpenListener.getUndertowOptions() |
OptionMap |
SpdyOpenListener.getUndertowOptions() |
Modifier and Type | Method and Description |
---|---|
void |
SpdyPlainOpenListener.setUndertowOptions(OptionMap undertowOptions) |
void |
SpdyOpenListener.setUndertowOptions(OptionMap undertowOptions) |
Constructor and Description |
---|
SpdyOpenListener(ByteBufferPool pool,
ByteBufferPool heapBufferPool,
OptionMap undertowOptions) |
SpdyOpenListener(Pool<ByteBuffer> pool,
Pool<ByteBuffer> heapBufferPool,
OptionMap undertowOptions)
Deprecated.
|
SpdyPlainOpenListener(ByteBufferPool pool,
ByteBufferPool heapBufferPool,
OptionMap undertowOptions) |
SpdyReceiveListener(HttpHandler rootHandler,
OptionMap undertowOptions,
int bufferSize,
ConnectorStatisticsImpl connectorStatistics) |
SpdyServerConnection(HttpHandler rootHandler,
SpdyChannel channel,
SpdySynStreamStreamSinkChannel responseChannel,
OptionMap undertowOptions,
int bufferSize) |
SpdyServerConnection(HttpHandler rootHandler,
SpdyChannel channel,
SpdySynStreamStreamSourceChannel requestChannel,
OptionMap undertowOptions,
int bufferSize) |
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 |
EJBClientConfiguration.CommonConnectionCreationConfiguration.getChannelCreationOptions()
|
OptionMap |
EJBClientConfiguration.CommonConnectionCreationConfiguration.getConnectionCreationOptions()
Returns the
options that will be used during connection creation. |
OptionMap |
PropertiesBasedEJBClientConfiguration.getEndpointCreationOptions() |
OptionMap |
EJBClientConfiguration.getEndpointCreationOptions()
Returns the endpoint creation
options that will be used for creating the remoting
endpoint. |
OptionMap |
PropertiesBasedEJBClientConfiguration.getRemoteConnectionProviderCreationOptions() |
OptionMap |
EJBClientConfiguration.getRemoteConnectionProviderCreationOptions()
Returns the
options that will be used for creating a remote connection provider. |
Modifier and Type | Method and Description |
---|---|
static OptionMap |
RemotingConnectionUtil.addSilentLocalAuthOptionsIfApplicable(CallbackHandler callbackHandler,
OptionMap connectionCreationOptions)
Deprecated.
Adds the
jboss.sasl.local-user.quiet-auth property to the Options.SASL_PROPERTIES
in the passed connectionCreationOptions if
The passed callbackHandler is of type DefaultCallbackHandler
and the passed connectionCreationOptions doesn't already contain the Options.SASL_PROPERTIES
with the jboss.sasl.local-user.quiet-auth
|
Modifier and Type | Method and Description |
---|---|
static OptionMap |
RemotingConnectionUtil.addSilentLocalAuthOptionsIfApplicable(CallbackHandler callbackHandler,
OptionMap connectionCreationOptions)
Deprecated.
Adds the
jboss.sasl.local-user.quiet-auth property to the Options.SASL_PROPERTIES
in the passed connectionCreationOptions if
The passed callbackHandler is of type DefaultCallbackHandler
and the passed connectionCreationOptions doesn't already contain the Options.SASL_PROPERTIES
with the jboss.sasl.local-user.quiet-auth
|
static IoFuture<Connection> |
NetworkUtil.connect(Endpoint endpoint,
String protocol,
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 protocol,
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. |
Constructor and Description |
---|
RemotingConnectionEJBReceiver(Connection connection,
ReconnectHandler reconnectHandler,
OptionMap channelCreationOptions)
Deprecated.
|
RemotingConnectionEJBReceiver(Connection connection,
ReconnectHandler reconnectHandler,
OptionMap channelCreationOptions,
String remotingProtocol)
Construct a new instance.
|
Modifier and Type | Method and Description |
---|---|
OptionMap |
RemoteNamingStoreConnectionInfo.getChannelCreationOptions() |
OptionMap |
RemoteNamingStoreConnectionInfo.getConnectionOptions() |
Modifier and Type | Method and Description |
---|---|
Endpoint |
EndpointCache.get(String endpointName,
OptionMap endPointCreationOptions,
OptionMap remoteConnectionProviderOptions) |
RemoteNamingStore |
NamingStoreCache.getRemoteNamingStore(Endpoint clientEndpoint,
String connectionURL,
OptionMap connectOptions,
CallbackHandler callbackHandler,
long connectionTimeout,
OptionMap channelCreationOptions,
long channelCreationTimeoutInMillis,
List<RemoteContext.CloseTask> contextCloseTasks,
boolean randomServer)
Returns a
Channel for the passed connection properties. |
RemoteNamingStore |
NamingStoreCache.getRemoteNamingStore(Endpoint clientEndpoint,
String connectionURL,
OptionMap connectOptions,
CallbackHandler callbackHandler,
long connectionTimeout,
OptionMap channelCreationOptions,
long channelCreationTimeoutInMillis,
List<RemoteContext.CloseTask> contextCloseTasks,
boolean randomServer,
EJBClientHandler ejbClientHandler)
Returns a
Channel for the passed connection properties. |
Constructor and Description |
---|
HaRemoteNamingStore(long channelCreationTimeoutInMillis,
OptionMap channelCreationOptions,
long connectionTimeout,
CallbackHandler callbackHandler,
OptionMap connectOptions,
List<URI> connectionURIs,
Endpoint clientEndpoint,
boolean randomServer) |
RemoteNamingStoreConnectionInfo(Endpoint clientEndpoint,
URI connectURI,
OptionMap connectionOptions,
long connectionTimeoutInMillis,
CallbackHandler callbackHandler,
long channelCreationTimeoutInMillis,
OptionMap channelCreationOptions) |
Modifier and Type | Method and Description |
---|---|
Registration |
Endpoint.addConnectionProvider(String uriScheme,
ConnectionProviderFactory providerFactory,
OptionMap optionMap)
Register a connection provider for a URI scheme.
|
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,
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.
|
static Endpoint |
Remoting.createEndpoint(OptionMap optionMap)
Create an anonymous endpoint.
|
static Endpoint |
Remoting.createEndpoint(String endpointName,
OptionMap optionMap)
Create a new endpoint with the given configuration.
|
static Endpoint |
Remoting.createEndpoint(String endpointName,
Xnio xnio,
OptionMap optionMap)
Create an endpoint with the given configuration which manages its own worker.
|
static Endpoint |
Remoting.createEndpoint(String endpointName,
XnioWorker xnioWorker,
OptionMap optionMap)
Create an endpoint with the given configuration and existing worker.
|
IoFuture<Channel> |
Connection.openChannel(String serviceType,
OptionMap optionMap)
Open a channel to a remote service on this connection.
|
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)
Create a provider instance for an endpoint.
|
ConnectionProvider |
HttpUpgradeConnectionProviderFactory.createInstance(ConnectionProviderContext context,
OptionMap optionMap)
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(SocketAddress bindAddress,
SocketAddress destination,
OptionMap connectOptions,
Result<ConnectionHandlerFactory> result,
CallbackHandler callbackHandler,
XnioSsl xnioSsl)
Open an outbound connection, using the (optionally) given socket addresses as source and destination.
|
ExternalConnectionProvider.ConnectionAdaptor |
ExternalConnectionProvider.createConnectionAdaptor(OptionMap optionMap,
ServerAuthenticationProvider authenticationProvider)
Create a network server.
|
ConnectionProvider |
ConnectionProviderFactory.createInstance(ConnectionProviderContext context,
OptionMap optionMap)
Create a provider instance for an endpoint.
|
AcceptingChannel<? extends ConnectedStreamChannel> |
NetworkServerProvider.createServer(SocketAddress bindAddress,
OptionMap optionMap,
ServerAuthenticationProvider authenticationProvider,
XnioSsl xnioSsl)
Create a network server.
|
Cancellable |
ConnectionHandler.open(String serviceType,
Result<Channel> result,
OptionMap optionMap)
Open a request handler.
|
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.
|
abstract 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.
|
Constructor and Description |
---|
XnioWorker(Xnio xnio,
ThreadGroup threadGroup,
OptionMap optionMap,
Runnable terminationTask)
Construct a new instance.
|
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 © 2016 JBoss by Red Hat. All rights reserved.