Package | Description |
---|---|
org.jboss.ejb.client | |
org.jboss.ejb.client.remoting | |
org.jboss.naming.remote.client | |
org.jboss.remoting3 |
The base Remoting 3 API package.
|
org.jboss.remoting3.remote | |
org.jboss.remoting3.spi |
Service provider classes and interfaces.
|
org.xnio |
The main API package for XNIO.
|
org.xnio.sasl | |
org.xnio.ssl |
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)
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)
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,
InetSocketAddress destination,
InetSocketAddress sourceBindAddress,
OptionMap connectionCreationOptions,
CallbackHandler callbackHandler,
SSLContext sslContext)
Returns a
IoFuture to a Connection which is established to the destination host. |
static IoFuture<Connection> |
NetworkUtil.connect(Endpoint endpoint,
String destinationHost,
int destinationPort,
InetSocketAddress sourceBindAddress,
OptionMap connectionCreationOptions,
CallbackHandler callbackHandler,
SSLContext sslContext)
Returns a
IoFuture to a Connection which is established to the destination host. |
Constructor and Description |
---|
RemotingConnectionEJBReceiver(Connection connection,
ReconnectHandler reconnectHandler,
OptionMap channelCreationOptions)
Construct a new instance.
|
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. |
Constructor and Description |
---|
HaRemoteNamingStore(long channelCreationTimeoutInMillis,
OptionMap channelCreationOptions,
long connectionTimeout,
CallbackHandler callbackHandler,
OptionMap connectOptions,
List<URI> connectionURIs,
Endpoint clientEndpoint,
boolean randomServer) |
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.
|
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.
|
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.
|
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)
Accept a message connection at a destination address.
|
protected IoFuture<ConnectedMessageChannel> |
XnioWorker.acceptLocalDatagram(LocalSocketAddress destination,
ChannelListener<? super ConnectedMessageChannel> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Implementation helper method to accept a local (UNIX domain) datagram connection.
|
protected IoFuture<ConnectedStreamChannel> |
XnioWorker.acceptLocalStream(LocalSocketAddress destination,
ChannelListener<? super ConnectedStreamChannel> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Implementation helper method to accept a local (UNIX domain) stream connection.
|
IoFuture<ConnectedStreamChannel> |
XnioWorker.acceptStream(SocketAddress destination,
ChannelListener<? super ConnectedStreamChannel> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Accept a stream connection at a destination address.
|
protected IoFuture<ConnectedStreamChannel> |
XnioWorker.acceptTcpStream(InetSocketAddress destination,
ChannelListener<? super ConnectedStreamChannel> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Implementation helper method to accept a TCP connection.
|
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)
Connect to a remote stream server.
|
IoFuture<ConnectedMessageChannel> |
XnioWorker.connectDatagram(SocketAddress bindAddress,
SocketAddress destination,
ChannelListener<? super ConnectedMessageChannel> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Connect to a remote datagram server.
|
protected IoFuture<ConnectedMessageChannel> |
XnioWorker.connectLocalDatagram(LocalSocketAddress bindAddress,
LocalSocketAddress destination,
ChannelListener<? super ConnectedMessageChannel> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Implementation helper method to connect to a local (UNIX domain) datagram server.
|
protected IoFuture<ConnectedStreamChannel> |
XnioWorker.connectLocalStream(LocalSocketAddress bindAddress,
LocalSocketAddress destinationAddress,
ChannelListener<? super ConnectedStreamChannel> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Implementation helper method to connect to a local (UNIX domain) server.
|
IoFuture<ConnectedStreamChannel> |
XnioWorker.connectStream(SocketAddress destination,
ChannelListener<? super ConnectedStreamChannel> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Connect to a remote stream server.
|
IoFuture<ConnectedStreamChannel> |
XnioWorker.connectStream(SocketAddress destination,
ChannelListener<? super ConnectedStreamChannel> openListener,
OptionMap optionMap)
Connect to a remote stream server.
|
IoFuture<ConnectedStreamChannel> |
XnioWorker.connectStream(SocketAddress bindAddress,
SocketAddress destination,
ChannelListener<? super ConnectedStreamChannel> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Connect to a remote stream server.
|
protected IoFuture<ConnectedStreamChannel> |
XnioWorker.connectTcpStream(InetSocketAddress bindAddress,
InetSocketAddress destinationAddress,
ChannelListener<? super ConnectedStreamChannel> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Implementation helper method to connect to a TCP server.
|
protected IoFuture<ConnectedMessageChannel> |
XnioWorker.connectUdpDatagram(InetSocketAddress bindAddress,
InetSocketAddress destination,
ChannelListener<? super ConnectedMessageChannel> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Implementation helper method to connect to a UDP server.
|
protected AcceptingChannel<? extends ConnectedStreamChannel> |
XnioWorker.createLocalStreamServer(LocalSocketAddress bindAddress,
ChannelListener<? super AcceptingChannel<ConnectedStreamChannel>> 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)
Open a unidirectional stream pipe.
|
void |
XnioWorker.createPipe(ChannelListener<? super StreamChannel> leftOpenListener,
ChannelListener<? super StreamChannel> rightOpenListener,
OptionMap optionMap)
Open a bidirectional stream pipe.
|
AcceptingChannel<? extends ConnectedStreamChannel> |
XnioWorker.createStreamServer(SocketAddress bindAddress,
ChannelListener<? super AcceptingChannel<ConnectedStreamChannel>> acceptListener,
OptionMap optionMap)
Create a stream server, for TCP or UNIX domain servers.
|
protected AcceptingChannel<? extends ConnectedStreamChannel> |
XnioWorker.createTcpServer(InetSocketAddress bindAddress,
ChannelListener<? super AcceptingChannel<ConnectedStreamChannel>> 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.
|
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.
|
Constructor and Description |
---|
XnioWorker(Xnio xnio,
ThreadGroup threadGroup,
OptionMap optionMap,
Runnable terminationTask)
Construct a new instance.
|
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 © 2012 JBoss by Red Hat. All Rights Reserved.