org.forgerock.openicf.framework.client

Class ConnectionManager

java.lang.Object

org.forgerock.openicf.framework.client.RemoteConnectionInfoManagerFactory

org.forgerock.openicf.framework.client.ConnectionManager

All Implemented Interfaces:

Closeable, AutoCloseable

public class ConnectionManager
extends RemoteConnectionInfoManagerFactory

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ConnectionManager.GracefulCloseEvent FilterChainEvent to gracefully complete the request-response processing when Connection is getting closed by the remote host.
static class	ConnectionManager.RemoteConnectionContext

Field Summary

Fields

Modifier and Type	Field and Description
protected ConcurrentMap<String,WebSocketConnectionGroup>	connectionGroups
static org.glassfish.grizzly.ssl.SSLContextConfigurator	DEFAULT_CONFIG
ReferenceCountedObject<ScheduledExecutorService>	DEFAULT_SCHEDULER The default scheduler which should be used when the application does not provide one.
static String	USER_AGENT

Constructor Summary

Constructors

Constructor and Description
ConnectionManager(OperationMessageListener messageListener, ConnectionManagerConfig config)

Method Summary

Modifier and Type	Method and Description
static String	computeBasicAuthentication(String principal, GuardedString password)
ClientRemoteConnectorInfoManager	connect(RemoteWSFrameworkConnectionInfo info)
protected org.glassfish.grizzly.ssl.SSLContextConfigurator	createSSLContextConfigurator(ConnectionManagerConfig clientConfig)
protected void	doClose()
protected void	init()
protected org.glassfish.grizzly.filterchain.FilterChain	initializeFilterChain(ConnectionManagerConfig clientConfig)
protected org.glassfish.grizzly.nio.transport.TCPNIOTransport	initializeNIOTransport(ConnectionManagerConfig connectionManagerConfig)

Methods inherited from class org.forgerock.openicf.framework.client.RemoteConnectionInfoManagerFactory

addCloseListener, close, getManagerConfig, getMessageListener, invokeCloseListener, isRunning, removeCloseListener

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_CONFIG

public static final org.glassfish.grizzly.ssl.SSLContextConfigurator DEFAULT_CONFIG

USER_AGENT

public static final String USER_AGENT

DEFAULT_SCHEDULER

public final ReferenceCountedObject<ScheduledExecutorService> DEFAULT_SCHEDULER

The default scheduler which should be used when the application does not provide one.

connectionGroups

protected final ConcurrentMap<String,WebSocketConnectionGroup> connectionGroups

Constructor Detail

ConnectionManager

public ConnectionManager(OperationMessageListener messageListener,
                         ConnectionManagerConfig config)
                  throws Exception

Throws:

Exception

Method Detail

init

protected void init()
             throws Exception

Throws:

Exception

doClose

protected void doClose()

Specified by:

doClose in class RemoteConnectionInfoManagerFactory

connect

public ClientRemoteConnectorInfoManager connect(RemoteWSFrameworkConnectionInfo info)

Specified by:

connect in class RemoteConnectionInfoManagerFactory

initializeNIOTransport

protected org.glassfish.grizzly.nio.transport.TCPNIOTransport initializeNIOTransport(ConnectionManagerConfig connectionManagerConfig)

initializeFilterChain

protected org.glassfish.grizzly.filterchain.FilterChain initializeFilterChain(ConnectionManagerConfig clientConfig)

createSSLContextConfigurator

protected org.glassfish.grizzly.ssl.SSLContextConfigurator createSSLContextConfigurator(ConnectionManagerConfig clientConfig)

computeBasicAuthentication

public static String computeBasicAuthentication(String principal,
                                                GuardedString password)
                                         throws UnsupportedEncodingException

Throws:

UnsupportedEncodingException