Class JtaTransactionCoordinatorImpl
java.lang.Object
org.hibernate.resource.transaction.backend.jta.internal.JtaTransactionCoordinatorImpl
- All Implemented Interfaces:
SynchronizationCallbackTarget
,TransactionCoordinator
public class JtaTransactionCoordinatorImpl
extends Object
implements TransactionCoordinator, SynchronizationCallbackTarget
An implementation of TransactionCoordinator based on managing a transaction through the JTA API (either TM or UT)
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionclass
Implementation of the LocalInflow for this TransactionCoordinator.Nested classes/interfaces inherited from interface org.hibernate.resource.transaction.spi.TransactionCoordinator
TransactionCoordinator.TransactionDriver
-
Constructor Summary
ConstructorsConstructorDescriptionJtaTransactionCoordinatorImpl
(TransactionCoordinatorBuilder transactionCoordinatorBuilder, TransactionCoordinatorOwner owner, boolean autoJoinTransactions, JtaPlatform jtaPlatform, boolean preferUserTransactions, boolean performJtaThreadTracking, TransactionObserver... observers) -
Method Summary
Modifier and TypeMethodDescriptionvoid
addObserver
(TransactionObserver observer) Adds an observer to the coordinator.void
afterCompletion
(boolean successful, boolean delayed) Callback of after-completion.void
Callback of before-completion.Retrieve an isolation delegate appropriate for this transaction strategy.void
Indicates an explicit request to join a transaction.Get access to the local registry of Synchronization instancesint
Access to the builder that generated this coordinatorGet the delegate used by the local transaction driver to control the underlying transactionvoid
boolean
isActive()
Is this transaction still active?boolean
isJoined()
Determine if there is an active transaction that this coordinator is already joined to.boolean
boolean
Is the RegisteredSynchronization used by Hibernate for unified JTA Synchronization callbacks registered for this coordinator?void
pulse()
Used by owner of the "JDBC session" as a means to indicate that implicit joining should be done if needed.void
removeObserver
(TransactionObserver observer) Remove an observer from the coordinator.void
setTimeOut
(int seconds) Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface org.hibernate.resource.transaction.spi.TransactionCoordinator
isTransactionActive, isTransactionActive
-
Constructor Details
-
JtaTransactionCoordinatorImpl
public JtaTransactionCoordinatorImpl(TransactionCoordinatorBuilder transactionCoordinatorBuilder, TransactionCoordinatorOwner owner, boolean autoJoinTransactions, JtaPlatform jtaPlatform, boolean preferUserTransactions, boolean performJtaThreadTracking, TransactionObserver... observers)
-
-
Method Details
-
getSynchronizationCallbackCoordinator
-
pulse
public void pulse()Description copied from interface:TransactionCoordinator
Used by owner of the "JDBC session" as a means to indicate that implicit joining should be done if needed.- Specified by:
pulse
in interfaceTransactionCoordinator
-
explicitJoin
public void explicitJoin()Description copied from interface:TransactionCoordinator
Indicates an explicit request to join a transaction. This is mainly intended to handle the JPA requirement aroundEntityManager.joinTransaction()
, and generally speaking only has an impact in JTA environments- Specified by:
explicitJoin
in interfaceTransactionCoordinator
-
isJoined
public boolean isJoined()Description copied from interface:TransactionCoordinator
Determine if there is an active transaction that this coordinator is already joined to.- Specified by:
isJoined
in interfaceTransactionCoordinator
- Returns:
true
if there is an active transaction this coordinator is already joined to;false
otherwise.
-
isSynchronizationRegistered
public boolean isSynchronizationRegistered()Is the RegisteredSynchronization used by Hibernate for unified JTA Synchronization callbacks registered for this coordinator?- Returns:
true
indicates that a RegisteredSynchronization is currently registered for this coordinator;false
indicates it is not (yet) registered.
-
getTransactionCoordinatorOwner
-
getJpaCompliance
- Specified by:
getJpaCompliance
in interfaceTransactionCoordinator
-
getTransactionDriverControl
Description copied from interface:TransactionCoordinator
Get the delegate used by the local transaction driver to control the underlying transaction- Specified by:
getTransactionDriverControl
in interfaceTransactionCoordinator
- Returns:
- The control delegate.
-
getLocalSynchronizations
Description copied from interface:TransactionCoordinator
Get access to the local registry of Synchronization instances- Specified by:
getLocalSynchronizations
in interfaceTransactionCoordinator
- Returns:
- The local Synchronization registry
-
isActive
public boolean isActive()Description copied from interface:TransactionCoordinator
Is this transaction still active?Answers on a best-effort basis. For example, in the case of JDBC based transactions we cannot know that a transaction is active when it is initiated directly through the JDBC
Connection
, only when it is initiated from here.- Specified by:
isActive
in interfaceSynchronizationCallbackTarget
- Specified by:
isActive
in interfaceTransactionCoordinator
- Returns:
true
if the transaction is still active;false
otherwise.
-
isJtaTransactionCurrentlyActive
public boolean isJtaTransactionCurrentlyActive() -
createIsolationDelegate
Description copied from interface:TransactionCoordinator
Retrieve an isolation delegate appropriate for this transaction strategy.- Specified by:
createIsolationDelegate
in interfaceTransactionCoordinator
- Returns:
- An isolation delegate.
-
getTransactionCoordinatorBuilder
Description copied from interface:TransactionCoordinator
Access to the builder that generated this coordinator- Specified by:
getTransactionCoordinatorBuilder
in interfaceTransactionCoordinator
-
setTimeOut
public void setTimeOut(int seconds) - Specified by:
setTimeOut
in interfaceTransactionCoordinator
-
getTimeOut
public int getTimeOut()- Specified by:
getTimeOut
in interfaceTransactionCoordinator
-
invalidate
public void invalidate()- Specified by:
invalidate
in interfaceTransactionCoordinator
-
beforeCompletion
public void beforeCompletion()Description copied from interface:SynchronizationCallbackTarget
Callback of before-completion.- Specified by:
beforeCompletion
in interfaceSynchronizationCallbackTarget
- See Also:
-
afterCompletion
public void afterCompletion(boolean successful, boolean delayed) Description copied from interface:SynchronizationCallbackTarget
Callback of after-completion.- Specified by:
afterCompletion
in interfaceSynchronizationCallbackTarget
- Parameters:
successful
- Was the transaction successful?- See Also:
-
addObserver
Description copied from interface:TransactionCoordinator
Adds an observer to the coordinator.Observers are not to be cleared on transaction completion.
- Specified by:
addObserver
in interfaceTransactionCoordinator
- Parameters:
observer
- The observer to add.
-
removeObserver
Description copied from interface:TransactionCoordinator
Remove an observer from the coordinator.- Specified by:
removeObserver
in interfaceTransactionCoordinator
- Parameters:
observer
- The observer to remove.
-