org.nuxeo.runtime.jtajca

Class NuxeoContainer

java.lang.Object

org.nuxeo.runtime.jtajca.NuxeoContainer

public class NuxeoContainer
extends Object

Internal helper for the Nuxeo-defined transaction manager and connection manager.

This code is called by the factories registered through JNDI, or by unit tests mimicking JNDI bindings.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	NuxeoContainer.ConnectionManagerWrapper Wraps a Geronimo ConnectionManager and adds a NuxeoContainer.ConnectionManagerWrapper.reset() method to flush the pool.
static class	NuxeoContainer.InstallContext
static class	NuxeoContainer.TransactionManagerConfiguration
static class	NuxeoContainer.TransactionManagerWrapper Wraps a transaction manager for providing a dummy recoverable interface.
static class	NuxeoContainer.UserTransactionImpl User transaction that uses this container's transaction manager.

Field Summary

Fields

Modifier and Type	Field and Description
protected static com.codahale.metrics.Counter	concurrentCount
protected static com.codahale.metrics.Counter	concurrentMaxCount
protected static Map<String,NuxeoContainer.ConnectionManagerWrapper>	connectionManagers
protected static String	jndiPrefix
protected static org.apache.commons.logging.Log	log
protected static Context	parentContext
protected static com.codahale.metrics.MetricRegistry	registry
protected static com.codahale.metrics.Counter	rollbackCount
protected static Context	rootContext
protected static ConcurrentHashMap<Transaction,com.codahale.metrics.Timer.Context>	timers
protected static TransactionManager	tm
protected static org.apache.geronimo.transaction.manager.RecoverableTransactionManager	tmRecoverable
protected static TransactionSynchronizationRegistry	tmSynchRegistry
protected static com.codahale.metrics.Timer	transactionTimer
protected static UserTransaction	ut

Method Summary

Modifier and Type	Method and Description
protected static void	addBinding(Context dir, Name name, Object obj)
protected static void	addDeepBinding(Context dir, CompositeName comp, Object obj)
static void	addDeepBinding(String name, Object obj) Bind object in root context.
static void	addListener(NuxeoContainerListener listener)
static NuxeoConnectionManager	createConnectionManager(NuxeoConnectionTrackingCoordinator coordinator, NuxeoConnectionManagerConfiguration config) Creates a Geronimo pooled connection manager using a Geronimo transaction manager.
protected static org.apache.geronimo.connector.outbound.connectionmanagerconfig.PoolingSupport	createPoolingSupport(NuxeoConnectionManagerConfiguration config)
protected static org.apache.geronimo.transaction.manager.TransactionManagerImpl	createTransactionManager(NuxeoContainer.TransactionManagerConfiguration config)
protected static org.apache.geronimo.connector.outbound.connectionmanagerconfig.TransactionSupport	createTransactionSupport(NuxeoConnectionManagerConfiguration config)
protected static NuxeoValidationSupport	createValidationSupport(NuxeoConnectionManagerConfiguration config)
protected static String	detectJNDIPrefix(Context context)
static void	disposeConnectionManager(javax.resource.spi.ConnectionManager mgr)
static NuxeoConnectionManager	getConnectionManager(String repositoryName) Gets the Nuxeo connection manager used by the container.
protected static Reference	getConnectionManagerReference(String name)
static Context	getRootContext() Exposes the rootContext.
static TransactionManager	getTransactionManager() Gets the transaction manager used by the container.
protected static Reference	getTransactionManagerReference()
static TransactionSynchronizationRegistry	getTransactionSynchronizationRegistry()
static UserTransaction	getUserTransaction() Gets the user transaction used by the container.
protected static Reference	getUserTransactionReference()
static NuxeoContainer.ConnectionManagerWrapper	initConnectionManager(NuxeoConnectionManagerConfiguration config)
protected static TransactionManager	initTransactionManager(NuxeoContainer.TransactionManagerConfiguration config)
protected static void	install() Install naming and bind transaction and connection management factories "by hand".
static NuxeoContainer.ConnectionManagerWrapper	installConnectionManager(NuxeoConnectionManagerConfiguration config) Creates and installs in the container a new ConnectionManager.
static void	installConnectionManager(NuxeoContainer.ConnectionManagerWrapper wrapper)
protected static void	installTransactionManager(Context context)
protected static void	installTransactionManager(NuxeoContainer.TransactionManagerConfiguration config)
static boolean	isInstalled()
static <T> T	lookup(Context context, String name, Class<T> type)
static <T> T	lookup(String name, Class<T> type)
protected static NuxeoContainer.ConnectionManagerWrapper	lookupConnectionManager(String repositoryName)
static String	nameOf(String name)
protected static void	removeBinding(String name)
static void	removeListener(NuxeoContainerListener listener)
static void	resetConnectionManager()
static void	resetConnectionManager(String name)
protected static void	uninstall()
protected static NuxeoContainer.TransactionManagerWrapper	wrapTransactionManager(TransactionManager tm)

Methods inherited from class java.lang.Object

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

Field Detail

log

protected static final org.apache.commons.logging.Log log

tmRecoverable

protected static org.apache.geronimo.transaction.manager.RecoverableTransactionManager tmRecoverable

tm

protected static TransactionManager tm

tmSynchRegistry

protected static TransactionSynchronizationRegistry tmSynchRegistry

ut

protected static UserTransaction ut

connectionManagers

protected static Map<String,NuxeoContainer.ConnectionManagerWrapper> connectionManagers

rootContext

protected static Context rootContext

parentContext

protected static Context parentContext

jndiPrefix

protected static String jndiPrefix

registry

protected static final com.codahale.metrics.MetricRegistry registry

rollbackCount

protected static final com.codahale.metrics.Counter rollbackCount

concurrentCount

protected static final com.codahale.metrics.Counter concurrentCount

concurrentMaxCount

protected static final com.codahale.metrics.Counter concurrentMaxCount

transactionTimer

protected static final com.codahale.metrics.Timer transactionTimer

timers

protected static final ConcurrentHashMap<Transaction,com.codahale.metrics.Timer.Context> timers

Method Detail

install

protected static void install()
                       throws NamingException

Install naming and bind transaction and connection management factories "by hand".

Throws:

NamingException

installTransactionManager

protected static void installTransactionManager(NuxeoContainer.TransactionManagerConfiguration config)
                                         throws NamingException

Throws:

NamingException

installConnectionManager

public static NuxeoContainer.ConnectionManagerWrapper installConnectionManager(NuxeoConnectionManagerConfiguration config)

Creates and installs in the container a new ConnectionManager.

Parameters:

name - the repository name

config - the pool configuration

Returns:

the created connection manager

isInstalled

public static boolean isInstalled()

uninstall

protected static void uninstall()
                         throws NamingException

Throws:

NamingException

addListener

public static void addListener(NuxeoContainerListener listener)

Since:

5.8

removeListener

public static void removeListener(NuxeoContainerListener listener)

Since:

5.8

detectJNDIPrefix

protected static String detectJNDIPrefix(Context context)

nameOf

public static String nameOf(String name)

getRootContext

public static Context getRootContext()

Exposes the rootContext.

Since:

5.7

See Also:

https://jira.nuxeo.com/browse/NXP-10331

addDeepBinding

public static void addDeepBinding(String name,
                                  Object obj)
                           throws NamingException

Bind object in root context. Create needed sub contexts. since 5.6

Throws:

NamingException

addDeepBinding

protected static void addDeepBinding(Context dir,
                                     CompositeName comp,
                                     Object obj)
                              throws NamingException

Throws:

NamingException

addBinding

protected static void addBinding(Context dir,
                                 Name name,
                                 Object obj)
                          throws NamingException

Throws:

NamingException

removeBinding

protected static void removeBinding(String name)
                             throws NamingException

Throws:

NamingException

getTransactionManager

public static TransactionManager getTransactionManager()

Gets the transaction manager used by the container.

Returns:

the transaction manager

getTransactionManagerReference

protected static Reference getTransactionManagerReference()

getUserTransaction

public static UserTransaction getUserTransaction()

Gets the user transaction used by the container.

Returns:

the user transaction

getUserTransactionReference

protected static Reference getUserTransactionReference()

getConnectionManager

public static NuxeoConnectionManager getConnectionManager(String repositoryName)

Gets the Nuxeo connection manager used by the container.

Returns:

the connection manager

installConnectionManager

public static void installConnectionManager(NuxeoContainer.ConnectionManagerWrapper wrapper)

getConnectionManagerReference

protected static Reference getConnectionManagerReference(String name)

initTransactionManager

protected static TransactionManager initTransactionManager(NuxeoContainer.TransactionManagerConfiguration config)

wrapTransactionManager

protected static NuxeoContainer.TransactionManagerWrapper wrapTransactionManager(TransactionManager tm)

initConnectionManager

public static NuxeoContainer.ConnectionManagerWrapper initConnectionManager(NuxeoConnectionManagerConfiguration config)

disposeConnectionManager

public static void disposeConnectionManager(javax.resource.spi.ConnectionManager mgr)

resetConnectionManager

public static void resetConnectionManager()

resetConnectionManager

public static void resetConnectionManager(String name)

lookup

public static <T> T lookup(String name,
                           Class<T> type)
                    throws NamingException

Throws:

NamingException

lookup

public static <T> T lookup(Context context,
                           String name,
                           Class<T> type)
                    throws NamingException

Throws:

NamingException

installTransactionManager

protected static void installTransactionManager(Context context)
                                         throws NamingException

Throws:

NamingException

lookupConnectionManager

protected static NuxeoContainer.ConnectionManagerWrapper lookupConnectionManager(String repositoryName)
                                                                          throws NamingException

Throws:

NamingException

createTransactionManager

protected static org.apache.geronimo.transaction.manager.TransactionManagerImpl createTransactionManager(NuxeoContainer.TransactionManagerConfiguration config)

createConnectionManager

public static NuxeoConnectionManager createConnectionManager(NuxeoConnectionTrackingCoordinator coordinator,
                                                             NuxeoConnectionManagerConfiguration config)

Creates a Geronimo pooled connection manager using a Geronimo transaction manager.

The pool uses the transaction manager for recovery, and when using XATransactions for cache + enlist/delist.

Throws:

NamingException

createPoolingSupport

protected static org.apache.geronimo.connector.outbound.connectionmanagerconfig.PoolingSupport createPoolingSupport(NuxeoConnectionManagerConfiguration config)

createTransactionSupport

protected static org.apache.geronimo.connector.outbound.connectionmanagerconfig.TransactionSupport createTransactionSupport(NuxeoConnectionManagerConfiguration config)

createValidationSupport

protected static NuxeoValidationSupport createValidationSupport(NuxeoConnectionManagerConfiguration config)

getTransactionSynchronizationRegistry

public static TransactionSynchronizationRegistry getTransactionSynchronizationRegistry()