org.apache.deltaspike.jpa.impl.transaction

Class BeanManagedUserTransactionStrategy

java.lang.Object

org.apache.deltaspike.jpa.impl.transaction.ResourceLocalTransactionStrategy

org.apache.deltaspike.jpa.impl.transaction.BeanManagedUserTransactionStrategy

All Implemented Interfaces:

Serializable, org.apache.deltaspike.core.spi.InterceptorStrategy, org.apache.deltaspike.jpa.spi.transaction.TransactionStrategy

Direct Known Subclasses:

EnvironmentAwareTransactionStrategy

@Dependent
@Alternative
public class BeanManagedUserTransactionStrategy
extends ResourceLocalTransactionStrategy

TransactionStrategy for using JTA (bean-managed-)transactions (including XA transactions with a XA DataSource). The basic features are identical to the ResourceLocalTransactionStrategy (for persistent-unit-transaction-type 'RESOURCE_LOCAL' only).

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected static String	USER_TRANSACTION_JNDI_NAME

Constructor Summary

Constructors

Constructor and Description
BeanManagedUserTransactionStrategy()

Method Summary

Methods

Modifier and Type	Method and Description
protected void	applyTransactionTimeout()
protected void	beforeProceed(EntityManagerEntry entityManagerEntry) Needed because the EntityManager might get created outside of the UserTransaction (e.g. depending on the implementation of the producer).
protected EntityManagerEntry	createEntityManagerEntry(javax.persistence.EntityManager entityManager, Class<? extends Annotation> qualifier)
protected Integer	getDefaultTransactionTimeoutInSeconds()
protected javax.persistence.EntityTransaction	getTransaction(EntityManagerEntry entityManagerEntry)
protected UserTransaction	resolveUserTransaction()

Methods inherited from class org.apache.deltaspike.jpa.impl.transaction.ResourceLocalTransactionStrategy

execute, onCloseTransactionScope, prepareException, resolveEntityManagerBean

Methods inherited from class java.lang.Object

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

Field Detail

USER_TRANSACTION_JNDI_NAME

protected static final String USER_TRANSACTION_JNDI_NAME

See Also:

Constant Field Values

Constructor Detail

BeanManagedUserTransactionStrategy

public BeanManagedUserTransactionStrategy()

Method Detail

createEntityManagerEntry

protected EntityManagerEntry createEntityManagerEntry(javax.persistence.EntityManager entityManager,
                                          Class<? extends Annotation> qualifier)

Overrides:

createEntityManagerEntry in class ResourceLocalTransactionStrategy

applyTransactionTimeout

protected void applyTransactionTimeout()

getDefaultTransactionTimeoutInSeconds

protected Integer getDefaultTransactionTimeoutInSeconds()

getTransaction

protected javax.persistence.EntityTransaction getTransaction(EntityManagerEntry entityManagerEntry)

Overrides:

getTransaction in class ResourceLocalTransactionStrategy

Parameters:

entityManagerEntry - entry of the current entity-manager

Returns:

per default the EntityTransaction of the given EntityManager. A subclass can also return an adapter e.g. for an UserTransaction

beforeProceed

protected void beforeProceed(EntityManagerEntry entityManagerEntry)

Needed because the EntityManager might get created outside of the UserTransaction (e.g. depending on the implementation of the producer). Can't be in BeanManagedUserTransactionStrategy.UserTransactionAdapter.begin() because ResourceLocalTransactionStrategy needs to do

 if (!transaction.isActive())
 {
     transaction.begin();
 }
 

for the EntityTransaction of every EntityManager and BeanManagedUserTransactionStrategy.UserTransactionAdapter.isActive() can only use the status information of the UserTransaction and therefore BeanManagedUserTransactionStrategy.UserTransactionAdapter.begin() will only executed once, but EntityManager.joinTransaction() needs to be called for every EntityManager.

Overrides:

beforeProceed in class ResourceLocalTransactionStrategy

Parameters:

entityManagerEntry - entry of the current entity-manager

resolveUserTransaction

protected UserTransaction resolveUserTransaction()