org.nuxeo.ecm.core.storage.sql.ra

Class ConnectionFactoryImpl

java.lang.Object

org.nuxeo.ecm.core.storage.sql.ra.ConnectionFactoryImpl

All Implemented Interfaces:

Serializable, Referenceable, ConnectionFactory, Repository, RepositoryManagement

public class ConnectionFactoryImpl
extends Object
implements Repository, Repository

The connection factory delegates connection requests to the application server ConnectionManager.

An instance of this class is returned to the application when a JNDI lookup is done. This is the datasource equivalent of SQLRepository.

Author:

Florent Guillaume

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ConnectionFactoryImpl(ManagedConnectionFactoryImpl managedConnectionFactory, ConnectionManager connectionManager)

Method Summary

Methods

Modifier and Type	Method and Description
void	activateServer() Activates the VCS server used for remote connections.
int	clearCaches() Clears all the caches.
void	close() Closes the repository and release all resources.
void	deactivateServer() Deactivates the VCS server used for remote connections.
int	getActiveSessionsCount() Gets the number of active sessions.
BinaryGarbageCollector	getBinaryGarbageCollector() Gets the binary GC for this repository.
Collection<MapperClientInfo>	getClientInfos() Get info about current VCS server clients
int	getClosedSessionsCount()
Session	getConnection() Gets a new connection, with no credentials.
Session	getConnection(ConnectionSpec connectionSpec) Gets a new connection.
ManagedConnectionFactoryImpl	getManagedConnectionFactory()
ResourceAdapterMetaData	getMetaData()
String	getName() Gets the repository name.
SecurityManager	getNuxeoSecurityManager()
Session[]	getOpenedSessions()
RecordFactory	getRecordFactory()
Reference	getReference()
String	getServerURL() Which is the remote location ? TODO this info would be better served by a provisioning service.
Session	getSession(long sessionId) Deprecated. unused
Session	getSession(Map<String,Serializable> context)
int	getStartedSessionsCount()
SchemaManager	getTypeManager()
void	initialize()
boolean	isServerActivated() Is the server available remotely ?
void	markReferencedBinaries(BinaryGarbageCollector gc) Marks the binaries actually in use with the GC so that they won't be deleted.
void	processClusterInvalidationsNext() Makes sure that the next transaction will process cluster invalidations.
void	setReference(Reference reference)
void	shutdown()
boolean	supportsTags()

Methods inherited from class java.lang.Object

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

Constructor Detail

ConnectionFactoryImpl

public ConnectionFactoryImpl(ManagedConnectionFactoryImpl managedConnectionFactory,
                     ConnectionManager connectionManager)

Method Detail

getManagedConnectionFactory

public ManagedConnectionFactoryImpl getManagedConnectionFactory()

getConnection

public Session getConnection()
                      throws StorageException

Gets a new connection, with no credentials.

Specified by:

getConnection in interface ConnectionFactory

Returns:

the connection

Throws:

StorageException

getConnection

public Session getConnection(ConnectionSpec connectionSpec)
                      throws StorageException

Gets a new connection.

Specified by:

getConnection in interface ConnectionFactory

Parameters:

connectionSpec - the connection spec, containing credentials

Returns:

the connection

Throws:

StorageException

getMetaData

public ResourceAdapterMetaData getMetaData()
                                    throws ResourceException

Specified by:

getMetaData in interface ConnectionFactory

Throws:

ResourceException

getRecordFactory

public RecordFactory getRecordFactory()
                               throws ResourceException

Specified by:

getRecordFactory in interface ConnectionFactory

Throws:

ResourceException

getReference

public Reference getReference()

Specified by:

getReference in interface Referenceable

setReference

public void setReference(Reference reference)

close

public void close()
           throws StorageException

Description copied from interface: Repository

Closes the repository and release all resources.

Throws:

StorageException

getName

public String getName()

Description copied from interface: RepositoryManagement

Gets the repository name.

Specified by:

getName in interface Repository

Specified by:

getName in interface RepositoryManagement

getSession

public Session getSession(Map<String,Serializable> context)
                   throws DocumentException

Specified by:

getSession in interface Repository

Throws:

DocumentException

getSession

@Deprecated
public Session getSession(long sessionId)
                   throws DocumentException

Deprecated. unused

Specified by:

getSession in interface Repository

Throws:

DocumentException

getNuxeoSecurityManager

public SecurityManager getNuxeoSecurityManager()

Specified by:

getNuxeoSecurityManager in interface Repository

getTypeManager

public SchemaManager getTypeManager()

Specified by:

getTypeManager in interface Repository

initialize

public void initialize()

Specified by:

initialize in interface Repository

getOpenedSessions

public Session[] getOpenedSessions()

Specified by:

getOpenedSessions in interface Repository

shutdown

public void shutdown()

Specified by:

shutdown in interface Repository

getStartedSessionsCount

public int getStartedSessionsCount()

Specified by:

getStartedSessionsCount in interface Repository

getClosedSessionsCount

public int getClosedSessionsCount()

Specified by:

getClosedSessionsCount in interface Repository

getActiveSessionsCount

public int getActiveSessionsCount()

Description copied from interface: RepositoryManagement

Gets the number of active sessions.

Specified by:

getActiveSessionsCount in interface Repository

Specified by:

getActiveSessionsCount in interface RepositoryManagement

clearCaches

public int clearCaches()

Description copied from interface: RepositoryManagement

Clears all the caches.

Specified by:

clearCaches in interface RepositoryManagement

Returns:

an indicative count of objects removed

processClusterInvalidationsNext

public void processClusterInvalidationsNext()

Description copied from interface: RepositoryManagement

Makes sure that the next transaction will process cluster invalidations.

Specified by:

processClusterInvalidationsNext in interface RepositoryManagement

getBinaryGarbageCollector

public BinaryGarbageCollector getBinaryGarbageCollector()

Description copied from interface: RepositoryManagement

Gets the binary GC for this repository.

Specified by:

getBinaryGarbageCollector in interface RepositoryManagement

Returns:

the binary garbage collector

markReferencedBinaries

public void markReferencedBinaries(BinaryGarbageCollector gc)

Description copied from interface: RepositoryManagement

Marks the binaries actually in use with the GC so that they won't be deleted.

The passed GC may or may not be the one returned by RepositoryManagement.getBinaryGarbageCollector() in case it's been determined that another repository's GC is pointing to the same binary data.

Specified by:

markReferencedBinaries in interface RepositoryManagement

Parameters:

gc - the binary garbage collector to use for this repository's binaries

supportsTags

public boolean supportsTags()

Specified by:

supportsTags in interface Repository

activateServer

public void activateServer()

Description copied from interface: RepositoryManagement

Activates the VCS server used for remote connections.

Specified by:

activateServer in interface RepositoryManagement

deactivateServer

public void deactivateServer()

Description copied from interface: RepositoryManagement

Deactivates the VCS server used for remote connections.

Specified by:

deactivateServer in interface RepositoryManagement

getClientInfos

public Collection<MapperClientInfo> getClientInfos()

Description copied from interface: RepositoryManagement

Get info about current VCS server clients

Specified by:

getClientInfos in interface RepositoryManagement

isServerActivated

public boolean isServerActivated()

Description copied from interface: RepositoryManagement

Is the server available remotely ?

Specified by:

isServerActivated in interface RepositoryManagement

getServerURL

public String getServerURL()

Description copied from interface: RepositoryManagement

Which is the remote location ? TODO this info would be better served by a provisioning service. The remote location is dependent to the context of access.

Specified by:

getServerURL in interface RepositoryManagement