org.jboss.remoting3

Class EndpointImpl

java.lang.Object

org.jboss.remoting3.spi.AbstractHandleableCloseable<Endpoint>

org.jboss.remoting3.EndpointImpl

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, Attachable, Endpoint, HandleableCloseable<Endpoint>

final class EndpointImpl
extends AbstractHandleableCloseable<Endpoint>
implements Endpoint

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private class	EndpointImpl.ConnectionCloseHandler
private class	EndpointImpl.ConnectionProviderContextImpl
(package private) class	EndpointImpl.LocalConnectionContext
private class	EndpointImpl.MapRegistration<T>
private static class	EndpointImpl.RegisteredServiceImpl
private class	EndpointImpl.TrackingExecutor
(package private) static class	EndpointImpl.UserAndRealm

Nested classes/interfaces inherited from interface org.jboss.remoting3.Endpoint

Endpoint.ListenerFlag

Nested classes/interfaces inherited from interface org.jboss.remoting3.HandleableCloseable

HandleableCloseable.Key

Field Summary

Fields

Modifier and Type	Field and Description
private static RemotingPermission	ADD_CONNECTION_PROVIDER_PERM
private Attachments	attachments
private static int	CLOSED_FLAG
private static RemotingPermission	CONNECT_PERM
private EndpointImpl.ConnectionCloseHandler	connectionCloseHandler
private java.lang.Object	connectionLock
private ConnectionProviderContext	connectionProviderContext
private java.util.concurrent.ConcurrentMap<java.lang.String,ConnectionProvider>	connectionProviders
private java.util.Set<ConnectionImpl>	connections
private static int	COUNT_MASK
private static EndpointImpl.UserAndRealm	EMPTY
private static java.lang.String	FQCN
private static RemotingPermission	GET_CONNECTION_PROVIDER_INTERFACE_PERM
private static org.jboss.logging.Logger	log
private java.lang.String	name The name of this endpoint.
private org.xnio.OptionMap	optionMap
private boolean	ourWorker
private static RemotingPermission	REGISTER_SERVICE_PERM
private java.util.concurrent.ConcurrentMap<java.lang.String,EndpointImpl.RegisteredServiceImpl>	registeredServices
private CloseHandler<java.lang.Object>	resourceCloseHandler
private int	resourceCount
private static java.util.concurrent.atomic.AtomicIntegerFieldUpdater<EndpointImpl>	resourceCountUpdater
private static java.nio.charset.Charset	UTF_8
private static java.util.regex.Pattern	VALID_SERVICE_PATTERN
private org.xnio.XnioWorker	worker
private org.xnio.Xnio	xnio

Constructor Summary

Constructors

Modifier	Constructor and Description
private	EndpointImpl(org.xnio.XnioWorker xnioWorker, boolean ourWorker, java.lang.String name, org.xnio.OptionMap optionMap)

Method Summary

Modifier and Type	Method and Description
Registration	addConnectionProvider(java.lang.String uriScheme, ConnectionProviderFactory providerFactory, org.xnio.OptionMap optionMap) Register a connection provider for a URI scheme.
protected void	closeAction() Called exactly once when the close() method is invoked; the actual close operation should take place here.
protected void	closeComplete() Call when close is complete.
private void	closeTick1(java.lang.Object c)
org.xnio.IoFuture<Connection>	connect(java.lang.String protocol, java.net.SocketAddress bindAddress, java.net.SocketAddress destination) Open a connection with a peer.
org.xnio.IoFuture<Connection>	connect(java.lang.String protocol, java.net.SocketAddress bindAddress, java.net.SocketAddress destination, org.xnio.OptionMap connectOptions) Open a connection with a peer.
org.xnio.IoFuture<Connection>	connect(java.lang.String protocol, java.net.SocketAddress bindAddress, java.net.SocketAddress destination, org.xnio.OptionMap connectOptions, javax.security.auth.callback.CallbackHandler callbackHandler) Open a connection with a peer.
org.xnio.IoFuture<Connection>	connect(java.lang.String protocol, java.net.SocketAddress bindAddress, java.net.SocketAddress destination, org.xnio.OptionMap connectOptions, javax.security.auth.callback.CallbackHandler callbackHandler, javax.net.ssl.SSLContext sslContext) Open a connection with a peer.
org.xnio.IoFuture<Connection>	connect(java.lang.String protocol, java.net.SocketAddress bindAddress, java.net.SocketAddress destination, org.xnio.OptionMap connectOptions, javax.security.auth.callback.CallbackHandler callbackHandler, org.xnio.ssl.XnioSsl xnioSsl) Open a connection with a peer.
org.xnio.IoFuture<Connection>	connect(java.lang.String protocol, java.net.SocketAddress bindAddress, java.net.SocketAddress destination, org.xnio.OptionMap connectOptions, java.lang.String userName, java.lang.String realmName, char[] password) Open a connection with a peer.
org.xnio.IoFuture<Connection>	connect(java.lang.String protocol, java.net.SocketAddress bindAddress, java.net.SocketAddress destination, org.xnio.OptionMap connectOptions, java.lang.String userName, java.lang.String realmName, char[] password, javax.net.ssl.SSLContext sslContext) Open a connection with a peer.
org.xnio.IoFuture<Connection>	connect(java.lang.String protocol, java.net.SocketAddress bindAddress, java.net.SocketAddress destination, org.xnio.OptionMap connectOptions, java.lang.String userName, java.lang.String realmName, char[] password, org.xnio.ssl.XnioSsl xnioSsl) Open a connection with a peer.
org.xnio.IoFuture<Connection>	connect(java.net.URI destination) Open a connection with a peer.
org.xnio.IoFuture<Connection>	connect(java.net.URI destination, org.xnio.OptionMap connectOptions) Open a connection with a peer.
org.xnio.IoFuture<Connection>	connect(java.net.URI destination, org.xnio.OptionMap connectOptions, javax.security.auth.callback.CallbackHandler callbackHandler) Open a connection with a peer.
org.xnio.IoFuture<Connection>	connect(java.net.URI destination, org.xnio.OptionMap connectOptions, javax.security.auth.callback.CallbackHandler callbackHandler, javax.net.ssl.SSLContext sslContext) Open a connection with a peer.
org.xnio.IoFuture<Connection>	connect(java.net.URI destination, org.xnio.OptionMap connectOptions, javax.security.auth.callback.CallbackHandler callbackHandler, org.xnio.ssl.XnioSsl xnioSsl) Open a connection with a peer.
org.xnio.IoFuture<Connection>	connect(java.net.URI destination, org.xnio.OptionMap connectOptions, java.lang.String userName, java.lang.String realmName, char[] password) Open a connection with a peer.
org.xnio.IoFuture<Connection>	connect(java.net.URI destination, org.xnio.OptionMap connectOptions, java.lang.String userName, java.lang.String realmName, char[] password, javax.net.ssl.SSLContext sslContext) Open a connection with a peer.
org.xnio.IoFuture<Connection>	connect(java.net.URI destination, org.xnio.OptionMap connectOptions, java.lang.String userName, java.lang.String realmName, char[] password, org.xnio.ssl.XnioSsl xnioSsl) Open a connection with a peer.
(package private) static EndpointImpl	construct(org.xnio.XnioWorker xnioWorker, boolean ourWorker, java.lang.String name, org.xnio.OptionMap optionMap)
private org.xnio.IoFuture<Connection>	doConnect(java.lang.String scheme, java.net.SocketAddress bindAddress, java.net.SocketAddress destination, org.xnio.OptionMap connectOptions, javax.security.auth.callback.CallbackHandler callbackHandler, org.xnio.ssl.XnioSsl xnioSsl)
private org.xnio.IoFuture<Connection>	doConnect(java.net.URI uri, org.xnio.OptionMap connectOptions, javax.security.auth.callback.CallbackHandler callbackHandler, org.xnio.ssl.XnioSsl xnioSsl)
(package private) void	executorUntick(java.lang.Object opened)
private void	finishPhase1()
Attachments	getAttachments() Get the attachments for this entity.
<T> T	getConnectionProviderInterface(java.lang.String uriScheme, java.lang.Class<T> expectedType) Get the interface for a connection provider.
java.util.concurrent.Executor	getExecutor() Get the executor to use for handler invocation.
java.lang.String	getName() Get the name of this endpoint.
private EndpointImpl.UserAndRealm	getUserAndRealm(java.net.URI uri)
org.xnio.XnioWorker	getXnioWorker() Get the XNIO worker configured for this endpoint.
(package private) boolean	isCloseFlagSet()
boolean	isValidUriScheme(java.lang.String uriScheme) Determine whether the given URI scheme is valid for this endpoint.
Registration	registerService(java.lang.String serviceType, OpenListener openListener, org.xnio.OptionMap optionMap) Register a new service.
(package private) void	resourceUntick(java.lang.Object opened)
java.lang.String	toString()
private static java.lang.String	uriDecode(java.lang.String encoded)

Methods inherited from class org.jboss.remoting3.spi.AbstractHandleableCloseable

addCloseHandler, awaitClosed, awaitClosedUninterruptibly, checkOpen, close, closeAsync, closeFailed, finalize, isOpen

Methods inherited from class java.lang.Object

clone, equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.jboss.remoting3.HandleableCloseable

addCloseHandler, awaitClosed, awaitClosedUninterruptibly, close, closeAsync

Field Detail

log

private static final org.jboss.logging.Logger log

REGISTER_SERVICE_PERM

private static final RemotingPermission REGISTER_SERVICE_PERM

CONNECT_PERM

private static final RemotingPermission CONNECT_PERM

ADD_CONNECTION_PROVIDER_PERM

private static final RemotingPermission ADD_CONNECTION_PROVIDER_PERM

GET_CONNECTION_PROVIDER_INTERFACE_PERM

private static final RemotingPermission GET_CONNECTION_PROVIDER_INTERFACE_PERM

CLOSED_FLAG

private static final int CLOSED_FLAG

See Also:

Constant Field Values

COUNT_MASK

private static final int COUNT_MASK

See Also:

Constant Field Values

FQCN

private static final java.lang.String FQCN

connections

private final java.util.Set<ConnectionImpl> connections

attachments

private final Attachments attachments

connectionProviders

private final java.util.concurrent.ConcurrentMap<java.lang.String,ConnectionProvider> connectionProviders

registeredServices

private final java.util.concurrent.ConcurrentMap<java.lang.String,EndpointImpl.RegisteredServiceImpl> registeredServices

xnio

private final org.xnio.Xnio xnio

worker

private final org.xnio.XnioWorker worker

connectionLock

private final java.lang.Object connectionLock

resourceCountUpdater

private static final java.util.concurrent.atomic.AtomicIntegerFieldUpdater<EndpointImpl> resourceCountUpdater

resourceCount

private volatile int resourceCount

VALID_SERVICE_PATTERN

private static final java.util.regex.Pattern VALID_SERVICE_PATTERN

name

private final java.lang.String name

The name of this endpoint.

optionMap

private final org.xnio.OptionMap optionMap

connectionProviderContext

private final ConnectionProviderContext connectionProviderContext

resourceCloseHandler

private final CloseHandler<java.lang.Object> resourceCloseHandler

connectionCloseHandler

private final EndpointImpl.ConnectionCloseHandler connectionCloseHandler

ourWorker

private final boolean ourWorker

UTF_8

private static final java.nio.charset.Charset UTF_8

EMPTY

private static final EndpointImpl.UserAndRealm EMPTY

Constructor Detail

EndpointImpl

private EndpointImpl(org.xnio.XnioWorker xnioWorker,
                     boolean ourWorker,
                     java.lang.String name,
                     org.xnio.OptionMap optionMap)
              throws java.io.IOException

Throws:

java.io.IOException

Method Detail

construct

static EndpointImpl construct(org.xnio.XnioWorker xnioWorker,
                              boolean ourWorker,
                              java.lang.String name,
                              org.xnio.OptionMap optionMap)
                       throws java.io.IOException

Throws:

java.io.IOException

getAttachments

public Attachments getAttachments()

Description copied from interface: Attachable

Get the attachments for this entity.

Specified by:

getAttachments in interface Attachable

Returns:

the attachments

getName

public java.lang.String getName()

Description copied from interface: Endpoint

Get the name of this endpoint.

Specified by:

getName in interface Endpoint

Returns:

the endpoint name, or null if there is no name

getExecutor

public java.util.concurrent.Executor getExecutor()

Description copied from class: AbstractHandleableCloseable

Get the executor to use for handler invocation.

Overrides:

getExecutor in class AbstractHandleableCloseable<Endpoint>

Returns:

the executor

closeComplete

protected void closeComplete()

Description copied from class: AbstractHandleableCloseable

Call when close is complete.

Overrides:

closeComplete in class AbstractHandleableCloseable<Endpoint>

closeTick1

private void closeTick1(java.lang.Object c)

finishPhase1

private void finishPhase1()

resourceUntick

void resourceUntick(java.lang.Object opened)
             throws NotOpenException

Throws:

NotOpenException

executorUntick

void executorUntick(java.lang.Object opened)

isCloseFlagSet

boolean isCloseFlagSet()

closeAction

protected void closeAction()
                    throws java.io.IOException

Description copied from class: AbstractHandleableCloseable

Called exactly once when the close() method is invoked; the actual close operation should take place here. This method must call AbstractHandleableCloseable.closeComplete(), directly or indirectly, for the close operation to finish (it may happen in another thread but it must happen). This method should not expect the AbstractHandleableCloseable.closeComplete() call to be made from another thread from the same thread pool that may cause AbstractHandleableCloseable.close(). As close will block, this can result in situations where all threads in the pool are blocked on AbstractHandleableCloseable.close() method calls, which means the AbstractHandleableCloseable.closeComplete() will never be run.

Overrides:

closeAction in class AbstractHandleableCloseable<Endpoint>

Throws:

RemotingException - if the close failed

java.io.IOException

registerService

public Registration registerService(java.lang.String serviceType,
                                    OpenListener openListener,
                                    org.xnio.OptionMap optionMap)
                             throws ServiceRegistrationException

Description copied from interface: Endpoint

Register a new service.

Specified by:

registerService in interface Endpoint

Parameters:

serviceType - the service type

openListener - the channel open listener

optionMap - the option map

Returns:

the service registration which may be closed to remove the service

Throws:

ServiceRegistrationException - if the service could not be registered

doConnect

private org.xnio.IoFuture<Connection> doConnect(java.net.URI uri,
                                                org.xnio.OptionMap connectOptions,
                                                javax.security.auth.callback.CallbackHandler callbackHandler,
                                                org.xnio.ssl.XnioSsl xnioSsl)
                                         throws java.io.IOException

Throws:

java.io.IOException

doConnect

private org.xnio.IoFuture<Connection> doConnect(java.lang.String scheme,
                                                java.net.SocketAddress bindAddress,
                                                java.net.SocketAddress destination,
                                                org.xnio.OptionMap connectOptions,
                                                javax.security.auth.callback.CallbackHandler callbackHandler,
                                                org.xnio.ssl.XnioSsl xnioSsl)
                                         throws java.io.IOException

Throws:

java.io.IOException

connect

public org.xnio.IoFuture<Connection> connect(java.net.URI destination)
                                      throws java.io.IOException

Description copied from interface: Endpoint

Open a connection with a peer. Returns a future connection which may be used to cancel the connection attempt. This method does not block; use the return value to wait for a result if you wish to block.

You must have the connect EndpointPermission to invoke this method.

Specified by:

connect in interface Endpoint

Parameters:

destination - the destination

Returns:

the future connection

Throws:

java.io.IOException - if an error occurs while starting the connect attempt

connect

public org.xnio.IoFuture<Connection> connect(java.net.URI destination,
                                             org.xnio.OptionMap connectOptions)
                                      throws java.io.IOException

Description copied from interface: Endpoint

Open a connection with a peer. Returns a future connection which may be used to cancel the connection attempt. This method does not block; use the return value to wait for a result if you wish to block.

You must have the connect EndpointPermission to invoke this method.

Specified by:

connect in interface Endpoint

Parameters:

destination - the destination

connectOptions - options to configure this connection

Returns:

the future connection

Throws:

java.io.IOException - if an error occurs while starting the connect attempt

connect

public org.xnio.IoFuture<Connection> connect(java.net.URI destination,
                                             org.xnio.OptionMap connectOptions,
                                             javax.security.auth.callback.CallbackHandler callbackHandler)
                                      throws java.io.IOException

Description copied from interface: Endpoint

Open a connection with a peer. Returns a future connection which may be used to cancel the connection attempt. The given callback handler is used to retrieve local authentication information, if the protocol demands it. This method does not block; use the return value to wait for a result if you wish to block.

You must have the connect EndpointPermission to invoke this method.

Specified by:

connect in interface Endpoint

Parameters:

destination - the destination

connectOptions - options to configure this connection

callbackHandler - the local callback handler to use for authentication

Returns:

the future connection

Throws:

java.io.IOException - if an error occurs while starting the connect attempt

connect

public org.xnio.IoFuture<Connection> connect(java.net.URI destination,
                                             org.xnio.OptionMap connectOptions,
                                             javax.security.auth.callback.CallbackHandler callbackHandler,
                                             javax.net.ssl.SSLContext sslContext)
                                      throws java.io.IOException

Description copied from interface: Endpoint

Open a connection with a peer. Returns a future connection which may be used to cancel the connection attempt. The given callback handler is used to retrieve local authentication information, if the protocol demands it. This method does not block; use the return value to wait for a result if you wish to block.

You must have the connect EndpointPermission to invoke this method.

Specified by:

connect in interface Endpoint

Parameters:

destination - the destination

connectOptions - options to configure this connection

callbackHandler - the local callback handler to use for authentication

sslContext - the SSL context to use for SSL connections

Returns:

the future connection

Throws:

java.io.IOException - if an error occurs while starting the connect attempt

connect

public org.xnio.IoFuture<Connection> connect(java.net.URI destination,
                                             org.xnio.OptionMap connectOptions,
                                             javax.security.auth.callback.CallbackHandler callbackHandler,
                                             org.xnio.ssl.XnioSsl xnioSsl)
                                      throws java.io.IOException

Description copied from interface: Endpoint

Open a connection with a peer. Returns a future connection which may be used to cancel the connection attempt. The given callback handler is used to retrieve local authentication information, if the protocol demands it. This method does not block; use the return value to wait for a result if you wish to block.

You must have the connect EndpointPermission to invoke this method.

Specified by:

connect in interface Endpoint

Parameters:

destination - the destination

connectOptions - options to configure this connection

callbackHandler - the local callback handler to use for authentication

xnioSsl - the SSL context to use for SSL connections

Returns:

the future connection

Throws:

java.io.IOException - if an error occurs while starting the connect attempt

connect

public org.xnio.IoFuture<Connection> connect(java.net.URI destination,
                                             org.xnio.OptionMap connectOptions,
                                             java.lang.String userName,
                                             java.lang.String realmName,
                                             char[] password)
                                      throws java.io.IOException

Description copied from interface: Endpoint

Open a connection with a peer. Returns a future connection which may be used to cancel the connection attempt. The given user name and password is used as local authentication information, if the protocol demands it. This method does not block; use the return value to wait for a result if you wish to block.

You must have the connect EndpointPermission to invoke this method.

Specified by:

connect in interface Endpoint

Parameters:

destination - the destination

connectOptions - options to configure this connection

userName - the user name to authenticate as, or null if it is unspecified

realmName - the user realm to authenticate with, or null if it is unspecified

password - the password to send, or null if it is unspecified

Returns:

the future connection

Throws:

java.io.IOException - if an error occurs while starting the connect attempt

connect

public org.xnio.IoFuture<Connection> connect(java.net.URI destination,
                                             org.xnio.OptionMap connectOptions,
                                             java.lang.String userName,
                                             java.lang.String realmName,
                                             char[] password,
                                             javax.net.ssl.SSLContext sslContext)
                                      throws java.io.IOException

Description copied from interface: Endpoint

Open a connection with a peer. Returns a future connection which may be used to cancel the connection attempt. The given user name and password is used as local authentication information, if the protocol demands it. This method does not block; use the return value to wait for a result if you wish to block.

You must have the connect EndpointPermission to invoke this method.

Specified by:

connect in interface Endpoint

Parameters:

destination - the destination

connectOptions - options to configure this connection

userName - the user name to authenticate as, or null if it is unspecified

realmName - the user realm to authenticate with, or null if it is unspecified

password - the password to send, or null if it is unspecified

sslContext - the SSL context to use for SSL connections

Returns:

the future connection

Throws:

java.io.IOException - if an error occurs while starting the connect attempt

connect

public org.xnio.IoFuture<Connection> connect(java.net.URI destination,
                                             org.xnio.OptionMap connectOptions,
                                             java.lang.String userName,
                                             java.lang.String realmName,
                                             char[] password,
                                             org.xnio.ssl.XnioSsl xnioSsl)
                                      throws java.io.IOException

Description copied from interface: Endpoint

Open a connection with a peer. Returns a future connection which may be used to cancel the connection attempt. The given user name and password is used as local authentication information, if the protocol demands it. This method does not block; use the return value to wait for a result if you wish to block.

You must have the connect EndpointPermission to invoke this method.

Specified by:

connect in interface Endpoint

Parameters:

destination - the destination

connectOptions - options to configure this connection

userName - the user name to authenticate as, or null if it is unspecified

realmName - the user realm to authenticate with, or null if it is unspecified

password - the password to send, or null if it is unspecified

xnioSsl - the SSL context to use for SSL connections

Returns:

the future connection

Throws:

java.io.IOException - if an error occurs while starting the connect attempt

connect

public org.xnio.IoFuture<Connection> connect(java.lang.String protocol,
                                             java.net.SocketAddress bindAddress,
                                             java.net.SocketAddress destination)
                                      throws java.io.IOException

Description copied from interface: Endpoint

Open a connection with a peer. Returns a future connection which may be used to cancel the connection attempt. This method does not block; use the return value to wait for a result if you wish to block.

You must have the connect EndpointPermission to invoke this method.

Specified by:

connect in interface Endpoint

Parameters:

protocol - the protocol to use for connection

bindAddress - the address to bind to, or null to choose one automatically as needed

destination - the destination address, or null if the protocol is not a network protocol

Returns:

the future connection

Throws:

java.io.IOException - if an error occurs while starting the connect attempt

connect

public org.xnio.IoFuture<Connection> connect(java.lang.String protocol,
                                             java.net.SocketAddress bindAddress,
                                             java.net.SocketAddress destination,
                                             org.xnio.OptionMap connectOptions)
                                      throws java.io.IOException

Description copied from interface: Endpoint

Open a connection with a peer. Returns a future connection which may be used to cancel the connection attempt. This method does not block; use the return value to wait for a result if you wish to block.

You must have the connect EndpointPermission to invoke this method.

Specified by:

connect in interface Endpoint

Parameters:

protocol - the protocol to use for connection

bindAddress - the address to bind to, or null to choose one automatically as needed

destination - the destination address, or null if the protocol is not a network protocol

connectOptions - options to configure this connection

Returns:

the future connection

Throws:

java.io.IOException - if an error occurs while starting the connect attempt

connect

public org.xnio.IoFuture<Connection> connect(java.lang.String protocol,
                                             java.net.SocketAddress bindAddress,
                                             java.net.SocketAddress destination,
                                             org.xnio.OptionMap connectOptions,
                                             javax.security.auth.callback.CallbackHandler callbackHandler)
                                      throws java.io.IOException

Description copied from interface: Endpoint

Open a connection with a peer. Returns a future connection which may be used to cancel the connection attempt. The given callback handler is used to retrieve local authentication information, if the protocol demands it. This method does not block; use the return value to wait for a result if you wish to block.

You must have the connect EndpointPermission to invoke this method.

Specified by:

connect in interface Endpoint

Parameters:

protocol - the protocol to use for connection

bindAddress - the address to bind to, or null to choose one automatically as needed

destination - the destination address, or null if the protocol is not a network protocol

connectOptions - options to configure this connection

callbackHandler - the local callback handler to use for authentication

Returns:

the future connection

Throws:

java.io.IOException - if an error occurs while starting the connect attempt

connect

public org.xnio.IoFuture<Connection> connect(java.lang.String protocol,
                                             java.net.SocketAddress bindAddress,
                                             java.net.SocketAddress destination,
                                             org.xnio.OptionMap connectOptions,
                                             javax.security.auth.callback.CallbackHandler callbackHandler,
                                             javax.net.ssl.SSLContext sslContext)
                                      throws java.io.IOException

Description copied from interface: Endpoint

Open a connection with a peer. Returns a future connection which may be used to cancel the connection attempt. The given callback handler is used to retrieve local authentication information, if the protocol demands it. This method does not block; use the return value to wait for a result if you wish to block.

You must have the connect EndpointPermission to invoke this method.

Specified by:

connect in interface Endpoint

Parameters:

protocol - the protocol to use for connection

bindAddress - the address to bind to, or null to choose one automatically as needed

destination - the destination address, or null if the protocol is not a network protocol

connectOptions - options to configure this connection

callbackHandler - the local callback handler to use for authentication

sslContext - the SSL context to use for SSL connections

Returns:

the future connection

Throws:

java.io.IOException - if an error occurs while starting the connect attempt

connect

public org.xnio.IoFuture<Connection> connect(java.lang.String protocol,
                                             java.net.SocketAddress bindAddress,
                                             java.net.SocketAddress destination,
                                             org.xnio.OptionMap connectOptions,
                                             javax.security.auth.callback.CallbackHandler callbackHandler,
                                             org.xnio.ssl.XnioSsl xnioSsl)
                                      throws java.io.IOException

Description copied from interface: Endpoint

Open a connection with a peer. Returns a future connection which may be used to cancel the connection attempt. The given callback handler is used to retrieve local authentication information, if the protocol demands it. This method does not block; use the return value to wait for a result if you wish to block.

You must have the connect EndpointPermission to invoke this method.

Specified by:

connect in interface Endpoint

Parameters:

protocol - the protocol to use for connection

bindAddress - the address to bind to, or null to choose one automatically as needed

destination - the destination address, or null if the protocol is not a network protocol

connectOptions - options to configure this connection

callbackHandler - the local callback handler to use for authentication

xnioSsl - the SSL context to use for SSL connections

Returns:

the future connection

Throws:

java.io.IOException - if an error occurs while starting the connect attempt

connect

public org.xnio.IoFuture<Connection> connect(java.lang.String protocol,
                                             java.net.SocketAddress bindAddress,
                                             java.net.SocketAddress destination,
                                             org.xnio.OptionMap connectOptions,
                                             java.lang.String userName,
                                             java.lang.String realmName,
                                             char[] password)
                                      throws java.io.IOException

Description copied from interface: Endpoint

Open a connection with a peer. Returns a future connection which may be used to cancel the connection attempt. The given user name and password is used as local authentication information, if the protocol demands it. This method does not block; use the return value to wait for a result if you wish to block.

You must have the connect EndpointPermission to invoke this method.

Specified by:

connect in interface Endpoint

Parameters:

protocol - the protocol to use for connection

bindAddress - the address to bind to, or null to choose one automatically as needed

destination - the destination address, or null if the protocol is not a network protocol

connectOptions - options to configure this connection

userName - the user name to authenticate as, or null if it is unspecified

realmName - the user realm to authenticate with, or null if it is unspecified

password - the password to send, or null if it is unspecified

Returns:

the future connection

Throws:

java.io.IOException - if an error occurs while starting the connect attempt

connect

public org.xnio.IoFuture<Connection> connect(java.lang.String protocol,
                                             java.net.SocketAddress bindAddress,
                                             java.net.SocketAddress destination,
                                             org.xnio.OptionMap connectOptions,
                                             java.lang.String userName,
                                             java.lang.String realmName,
                                             char[] password,
                                             javax.net.ssl.SSLContext sslContext)
                                      throws java.io.IOException

Description copied from interface: Endpoint

Open a connection with a peer. Returns a future connection which may be used to cancel the connection attempt. The given user name and password is used as local authentication information, if the protocol demands it. This method does not block; use the return value to wait for a result if you wish to block.

You must have the connect EndpointPermission to invoke this method.

Specified by:

connect in interface Endpoint

Parameters:

protocol - the protocol to use for connection

bindAddress - the address to bind to, or null to choose one automatically as needed

destination - the destination address, or null if the protocol is not a network protocol

connectOptions - options to configure this connection

userName - the user name to authenticate as, or null if it is unspecified

realmName - the user realm to authenticate with, or null if it is unspecified

password - the password to send, or null if it is unspecified

sslContext - the SSL context to use for SSL connections

Returns:

the future connection

Throws:

java.io.IOException - if an error occurs while starting the connect attempt

connect

public org.xnio.IoFuture<Connection> connect(java.lang.String protocol,
                                             java.net.SocketAddress bindAddress,
                                             java.net.SocketAddress destination,
                                             org.xnio.OptionMap connectOptions,
                                             java.lang.String userName,
                                             java.lang.String realmName,
                                             char[] password,
                                             org.xnio.ssl.XnioSsl xnioSsl)
                                      throws java.io.IOException

Description copied from interface: Endpoint

Open a connection with a peer. Returns a future connection which may be used to cancel the connection attempt. The given user name and password is used as local authentication information, if the protocol demands it. This method does not block; use the return value to wait for a result if you wish to block.

You must have the connect EndpointPermission to invoke this method.

Specified by:

connect in interface Endpoint

Parameters:

protocol - the protocol to use for connection

bindAddress - the address to bind to, or null to choose one automatically as needed

destination - the destination address, or null if the protocol is not a network protocol

connectOptions - options to configure this connection

userName - the user name to authenticate as, or null if it is unspecified

realmName - the user realm to authenticate with, or null if it is unspecified

password - the password to send, or null if it is unspecified

xnioSsl - the SSL context to use for SSL connections

Returns:

the future connection

Throws:

java.io.IOException - if an error occurs while starting the connect attempt

addConnectionProvider

public Registration addConnectionProvider(java.lang.String uriScheme,
                                          ConnectionProviderFactory providerFactory,
                                          org.xnio.OptionMap optionMap)
                                   throws java.io.IOException

Description copied from interface: Endpoint

Register a connection provider for a URI scheme. The provider factory is called with the context which can be used to accept new connections or terminate the registration.

You must have the addConnectionProvider EndpointPermission to invoke this method.

Specified by:

addConnectionProvider in interface Endpoint

Parameters:

uriScheme - the URI scheme

providerFactory - the provider factory

optionMap - the configuration options for the connection provider

Returns:

a handle which may be used to remove the registration

Throws:

java.io.IOException - if the provider failed to initialize

getConnectionProviderInterface

public <T> T getConnectionProviderInterface(java.lang.String uriScheme,
                                            java.lang.Class<T> expectedType)
                                     throws UnknownURISchemeException,
                                            java.lang.ClassCastException

Description copied from interface: Endpoint

Get the interface for a connection provider.

You must have the getConnectionProviderInterface EndpointPermission to invoke this method.

Specified by:

getConnectionProviderInterface in interface Endpoint

Type Parameters:

T - the expected type of the interface

Parameters:

uriScheme - the URI scheme of the registered connection provider

expectedType - the expected type of the interface

Returns:

the provider interface

Throws:

UnknownURISchemeException - if the given URI scheme is not registered

java.lang.ClassCastException - if the interface type does not match the expected type

isValidUriScheme

public boolean isValidUriScheme(java.lang.String uriScheme)

Description copied from interface: Endpoint

Determine whether the given URI scheme is valid for this endpoint.

Specified by:

isValidUriScheme in interface Endpoint

Parameters:

uriScheme - the URI scheme

Returns:

true if the URI scheme is valid at the time this method is called

getXnioWorker

public org.xnio.XnioWorker getXnioWorker()

Description copied from interface: Endpoint

Get the XNIO worker configured for this endpoint.

Specified by:

getXnioWorker in interface Endpoint

Returns:

the XNIO worker

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

uriDecode

private static java.lang.String uriDecode(java.lang.String encoded)

getUserAndRealm

private EndpointImpl.UserAndRealm getUserAndRealm(java.net.URI uri)