org.apache.deltaspike.jpa.impl.transaction

Class EnvironmentAwareTransactionStrategy

java.lang.Object

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

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

org.apache.deltaspike.jpa.impl.transaction.EnvironmentAwareTransactionStrategy

All Implemented Interfaces:

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

@Dependent
@Alternative
public class EnvironmentAwareTransactionStrategy
extends BeanManagedUserTransactionStrategy

This alternative TransactionStrategy uses auto-detection and can be used for different (parallel) persistence-units which use different transaction-types or if different environments (dev., prod.,...) should use different transaction-types.

This implementation can be used for environments which allow a mixed usage of JTA and RESOURCE_LOCAL. (Within a transactional call it isn't possible to mix different transaction-types.) E.g.: in an application-server this class allows to use a persistence-unit with transaction-type="RESOURCE_LOCAL" + non-jta-data-source in parallel to a persistence-unit with transaction-type="JTA" + jta-data-source

Optional:
E.g. in case of a project-stage based logic org.apache.deltaspike.core.api.exclude.Exclude can be used to switch between different producer-beans.

It's a better alternative than extending BeanManagedUserTransactionStrategy (which would lead to an impl. dependency) only for using org.apache.deltaspike.core.api.exclude.Exclude at the custom TransactionStrategy (or doing a custom veto-extension).

See Also:

Serialized Form

Field Summary

Fields inherited from class org.apache.deltaspike.jpa.impl.transaction.BeanManagedUserTransactionStrategy

USER_TRANSACTION_JNDI_NAME

Constructor Summary

Constructors

Constructor and Description
EnvironmentAwareTransactionStrategy()

Method Summary

Methods

Modifier and Type	Method and Description
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 javax.persistence.EntityTransaction	getTransaction(EntityManagerEntry entityManagerEntry)
protected void	onCloseTransactionScope()

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

applyTransactionTimeout, getDefaultTransactionTimeoutInSeconds, resolveUserTransaction

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

execute, prepareException, resolveEntityManagerBean

Methods inherited from class java.lang.Object

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

Constructor Detail

EnvironmentAwareTransactionStrategy

public EnvironmentAwareTransactionStrategy()

Method Detail

createEntityManagerEntry

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

Overrides:

createEntityManagerEntry in class BeanManagedUserTransactionStrategy

beforeProceed

protected void beforeProceed(EntityManagerEntry entityManagerEntry)

Description copied from class: BeanManagedUserTransactionStrategy

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 BeanManagedUserTransactionStrategy

Parameters:

entityManagerEntry - entry of the current entity-manager

getTransaction

protected javax.persistence.EntityTransaction getTransaction(EntityManagerEntry entityManagerEntry)

Overrides:

getTransaction in class BeanManagedUserTransactionStrategy

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

onCloseTransactionScope

protected void onCloseTransactionScope()

Overrides:

onCloseTransactionScope in class ResourceLocalTransactionStrategy