org.jboss.as.jpa.container

Class ExtendedEntityManager

java.lang.Object

org.jboss.as.jpa.container.AbstractEntityManager

org.jboss.as.jpa.container.ExtendedEntityManager

All Implemented Interfaces:

Serializable, javax.persistence.EntityManager

public class ExtendedEntityManager
extends AbstractEntityManager
implements Serializable

Represents the Extended persistence context injected into a stateful bean. At bean invocation time, will join the active JTA transaction if one is present. If no active JTA transaction is present, created/deleted/updated/loaded entities will remain associated with the entity manager until it is joined with a transaction (commit will save the changes, rollback will lose them).

At injection time, an instance of this class is associated with the SFSB. During a SFSB1 invocation, if a new SFSB2 is created with an XPC referencing the same persistence unit, the new SFSB2 will inherit the same persistence context from SFSB1. Both SFSB1 + SFSB2 will maintain a reference to the underlying persistence context, such that the underlying persistence context will be kept around until both SFSB1 + SFSB2 are destroyed. At cluster replication time or passivation, both SFSB1 + SFSB2 will be serialized consecutively and this instance will only be serialized once.

Note: Unlike TransactionScopedEntityManager, ExtendedEntityManager will directly be shared instead of the underlying EntityManager.

During serialization, A NotSerializableException will be thrown if the following conditions are not met: - The underlying persistence provider (entity manager) must be Serializable. - The entity classes in the extended persistence context must also be Serializable.

Author:

Scott Marlow

See Also:

Serialized Form

Field Summary

Fields inherited from class org.jboss.as.jpa.container.AbstractEntityManager

NONE_LOCK_MODE, NULL_LOCK_MODE, OPTIMISTIC_FORCE_INCREMENT_LOCK_MODE, OPTIMISTIC_LOCK_MODE, PESSIMISTIC_FORCE_INCREMENT_LOCK_MODE, PESSIMISTIC_READ_LOCK_MODE, PESSIMISTIC_WRITE_LOCK_MODE, READ_LOCK_MODE, WRITE_LOCK_MODE

Constructor Summary

Constructors

Constructor and Description
ExtendedEntityManager(String puScopedName, javax.persistence.EntityManager underlyingEntityManager, javax.persistence.SynchronizationType synchronizationType)

Method Summary

Modifier and Type	Method and Description
void	close() Catch the application trying to close the container managed entity manager and throw an IllegalStateException
boolean	equals(Object otherObject) Check if this object's UUID is equal to the otherObject's UUID
protected javax.persistence.EntityManager	getEntityManager() The JPA SFSB interceptor will track the stack of SFSB invocations.
int	getReferenceCount()
String	getScopedPuName() Get the fully application scoped persistence unit name Private api
javax.persistence.SynchronizationType	getSynchronizationType()
int	hashCode()
void	increaseReferenceCount() Start of reference count handling.
void	internalAssociateWithJtaTx() Associate the extended persistence context with the current JTA transaction (if one is found) this method is private to the JPA subsystem
protected boolean	isExtendedPersistenceContext()
protected boolean	isInTx()
void	refCountedClose()
String	toString() End of reference count handling

Methods inherited from class org.jboss.as.jpa.container.AbstractEntityManager

clear, contains, createEntityGraph, createEntityGraph, createNamedQuery, createNamedQuery, createNamedStoredProcedureQuery, createNativeQuery, createNativeQuery, createNativeQuery, createQuery, createQuery, createQuery, createQuery, createQuery, createStoredProcedureQuery, createStoredProcedureQuery, createStoredProcedureQuery, detach, detachNonTxInvocation, detachQueryNonTxInvocation, detachTypedQueryNonTxInvocation, find, find, find, find, flush, getCriteriaBuilder, getDelegate, getEntityGraph, getEntityGraphs, getEntityManagerFactory, getFlushMode, getLockMode, getMetamodel, getProperties, getReference, getTransaction, isJoinedToTransaction, isOpen, joinTransaction, lock, lock, merge, persist, refresh, refresh, refresh, refresh, remove, setFlushMode, setProperty, unwrap

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

ExtendedEntityManager

public ExtendedEntityManager(String puScopedName,
                             javax.persistence.EntityManager underlyingEntityManager,
                             javax.persistence.SynchronizationType synchronizationType)

Method Detail

getEntityManager

protected javax.persistence.EntityManager getEntityManager()

The JPA SFSB interceptor will track the stack of SFSB invocations. The underlying EM will be obtained from the current SFSB being invoked (via our JPA SFSB interceptor). Every entity manager call (to AbstractEntityManager) will call this method to get the underlying entity manager (e.g. the Hibernate persistence provider). See org.jboss.ejb3.stateful.EJB3XPCResolver.getExtendedPersistenceContext() to see the as6 implementation of this.

Specified by:

getEntityManager in class AbstractEntityManager

Returns:

EntityManager

internalAssociateWithJtaTx

public void internalAssociateWithJtaTx()

Associate the extended persistence context with the current JTA transaction (if one is found) this method is private to the JPA subsystem

isExtendedPersistenceContext

protected boolean isExtendedPersistenceContext()

Specified by:

isExtendedPersistenceContext in class AbstractEntityManager

Returns:

true if an extended persistence context is in use

Precondition: getEntityManager() must be called previous to calling isExtendedPersistenceContext

isInTx

protected boolean isInTx()

Specified by:

isInTx in class AbstractEntityManager

Returns:

true if a JTA transaction is active

Precondition: getEntityManager() must be called previous to calling isInTx

close

public void close()

Catch the application trying to close the container managed entity manager and throw an IllegalStateException

Specified by:

close in interface javax.persistence.EntityManager

Overrides:

close in class AbstractEntityManager

increaseReferenceCount

public void increaseReferenceCount()

Start of reference count handling. synchronize on *this* to protect access to the referenceCount (should be mostly uncontended locks).

getReferenceCount

public int getReferenceCount()

refCountedClose

public void refCountedClose()

toString

public String toString()

End of reference count handling

Overrides:

toString in class Object

getScopedPuName

public String getScopedPuName()

Get the fully application scoped persistence unit name Private api

Returns:

scoped pu name

equals

public boolean equals(Object otherObject)

Check if this object's UUID is equal to the otherObject's UUID

Overrides:

equals in class Object

Parameters:

otherObject -

Returns:

hashCode

public int hashCode()

Overrides:

hashCode in class Object

getSynchronizationType

public javax.persistence.SynchronizationType getSynchronizationType()

Specified by:

getSynchronizationType in class AbstractEntityManager