org.jboss.remoting3

Class ConnectionImpl

java.lang.Object

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

org.jboss.remoting3.ConnectionImpl

All Implemented Interfaces:

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

class ConnectionImpl
extends AbstractHandleableCloseable<Connection>
implements Connection

Nested Class Summary

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

HandleableCloseable.Key

Field Summary

Fields

Modifier and Type	Field and Description
private Attachments	attachments
private ConnectionHandler	connectionHandler
private Endpoint	endpoint

Constructor Summary

Constructors

Constructor and Description
ConnectionImpl(EndpointImpl endpoint, ConnectionHandlerFactory connectionHandlerFactory, ConnectionProviderContext connectionProviderContext)

Method Summary

Modifier and Type	Method and Description
protected void	closeAction() Called exactly once when the close() method is invoked; the actual close operation should take place here.
Attachments	getAttachments() Get the attachments for this entity.
(package private) ConnectionHandler	getConnectionHandler()
Endpoint	getEndpoint() Get the local endpoint.
java.util.Collection<java.security.Principal>	getPrincipals() Get the authenticated principals for this connection.
java.lang.String	getRemoteEndpointName() Get the name of the remote endpoint, if it has one.
javax.net.ssl.SSLSession	getSslSession() Get the underlying SSLSession for this connection if one is established.
UserInfo	getUserInfo() Get the UserInfo for this connection.
org.xnio.IoFuture<Channel>	openChannel(java.lang.String serviceType, org.xnio.OptionMap optionMap) Open a channel to a remote service on this connection.
java.lang.String	toString()

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

addCloseHandler, awaitClosed, awaitClosedUninterruptibly, checkOpen, close, closeAsync, closeComplete, closeFailed, finalize, getExecutor, 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

attachments

private final Attachments attachments

connectionHandler

private final ConnectionHandler connectionHandler

endpoint

private final Endpoint endpoint

Constructor Detail

ConnectionImpl

ConnectionImpl(EndpointImpl endpoint,
               ConnectionHandlerFactory connectionHandlerFactory,
               ConnectionProviderContext connectionProviderContext)

Method Detail

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<Connection>

Throws:

RemotingException - if the close failed

java.io.IOException

getConnectionHandler

ConnectionHandler getConnectionHandler()

getPrincipals

public java.util.Collection<java.security.Principal> getPrincipals()

Description copied from interface: Connection

Get the authenticated principals for this connection.

Specified by:

getPrincipals in interface Connection

Returns:

the authenticated principals

getUserInfo

public UserInfo getUserInfo()

Description copied from interface: Connection

Get the UserInfo for this connection.

Specified by:

getUserInfo in interface Connection

Returns:

the authenticated UserInfo

getSslSession

public javax.net.ssl.SSLSession getSslSession()

Description copied from interface: Connection

Get the underlying SSLSession for this connection if one is established.

Specified by:

getSslSession in interface Connection

Returns:

the SSLSession for the connection if one is established, otherwise returns null.

openChannel

public org.xnio.IoFuture<Channel> openChannel(java.lang.String serviceType,
                                              org.xnio.OptionMap optionMap)

Description copied from interface: Connection

Open a channel to a remote service on this connection.

Specified by:

openChannel in interface Connection

Parameters:

serviceType - the service type

optionMap - the option map

Returns:

the future channel

getRemoteEndpointName

public java.lang.String getRemoteEndpointName()

Description copied from interface: Connection

Get the name of the remote endpoint, if it has one.

Specified by:

getRemoteEndpointName in interface Connection

Returns:

the remote endpoint name or null if it is anonymous

getEndpoint

public Endpoint getEndpoint()

Description copied from interface: Connection

Get the local endpoint.

Specified by:

getEndpoint in interface Connection

Returns:

the local endpoint

getAttachments

public Attachments getAttachments()

Description copied from interface: Attachable

Get the attachments for this entity.

Specified by:

getAttachments in interface Attachable

Returns:

the attachments

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object