Nested and Inner Type Summary

Modifier and Type	Class and Description
public class	JtaTransactionCoordinatorImpl.TransactionDriverControlImpl Implementation of the LocalInflow for this TransactionCoordinator.

Modifier and Type	Field and Description
private final boolean	autoJoinTransactions
private SynchronizationCallbackCoordinator	callbackCoordinator
private final JtaPlatform	jtaPlatform
private static final Logger	log
private transient List<TransactionObserver>	observers
private final boolean	performJtaThreadTracking
private JtaTransactionCoordinatorImpl.TransactionDriverControlImpl	physicalTransactionDelegate
private final boolean	preferUserTransactions
private boolean	synchronizationRegistered
private final SynchronizationRegistryStandardImpl	synchronizationRegistry
private int	timeOut
private final TransactionCoordinatorBuilder	transactionCoordinatorBuilder
private final TransactionCoordinatorOwner	transactionCoordinatorOwner

Constructor Summary

Access	Constructor and Description
pack-priv	JtaTransactionCoordinatorImpl(TransactionCoordinatorBuilder transactionCoordinatorBuilder, TransactionCoordinatorOwner The transactionCoordinatorOwner owner, boolean Should JTA transactions be auto-joined? Or should we wait for explicit join calls? autoJoinTransactions, JtaPlatform jtaPlatform) Construct a JtaTransactionCoordinatorImpl instance.
public	JtaTransactionCoordinatorImpl(TransactionCoordinatorBuilder transactionCoordinatorBuilder, TransactionCoordinatorOwner owner, boolean autoJoinTransactions, JtaPlatform jtaPlatform, boolean preferUserTransactions, boolean performJtaThreadTracking, TransactionObserver... observers)

Method Summary

Modifier and Type	Method and Description
public void	addObserver(TransactionObserver The observer to add. observer) Implements org.hibernate.resource.transaction.spi.TransactionCoordinator.addObserver. Adds an observer to the coordinator.
public void	afterCompletion(boolean Was the transaction successful? successful, boolean delayed) Implements org.hibernate.resource.transaction.backend.jta.internal.synchronization.SynchronizationCallbackTarget.afterCompletion. Callback of after-completion.
public void	beforeCompletion() Implements org.hibernate.resource.transaction.backend.jta.internal.synchronization.SynchronizationCallbackTarget.beforeCompletion. Callback of before-completion.
public IsolationDelegate	createIsolationDelegate() Implements org.hibernate.resource.transaction.spi.TransactionCoordinator.createIsolationDelegate. Retrieve an isolation delegate appropriate for this transaction strategy.
public void	explicitJoin() Implements org.hibernate.resource.transaction.spi.TransactionCoordinator.explicitJoin. Indicates an explicit request to join a transaction.
public JpaCompliance	getJpaCompliance() Implements org.hibernate.resource.transaction.spi.TransactionCoordinator.getJpaCompliance.
public SynchronizationRegistry	getLocalSynchronizations() Implements org.hibernate.resource.transaction.spi.TransactionCoordinator.getLocalSynchronizations. Get access to the local registry of Synchronization instances
public SynchronizationCallbackCoordinator	getSynchronizationCallbackCoordinator()
public int	getTimeOut() Implements org.hibernate.resource.transaction.spi.TransactionCoordinator.getTimeOut.
public TransactionCoordinatorBuilder	getTransactionCoordinatorBuilder() Implements org.hibernate.resource.transaction.spi.TransactionCoordinator.getTransactionCoordinatorBuilder. Access to the builder that generated this coordinator
public TransactionCoordinatorOwner	getTransactionCoordinatorOwner()
public TransactionCoordinator.TransactionDriver	getTransactionDriverControl() Implements org.hibernate.resource.transaction.spi.TransactionCoordinator.getTransactionDriverControl. Get the delegate used by the local transaction driver to control the underlying transaction
public void	invalidate() Overrides default org.hibernate.resource.transaction.spi.TransactionCoordinator.invalidate.
public boolean	isActive() Implements org.hibernate.resource.transaction.spi.TransactionCoordinator.isActive, org.hibernate.resource.transaction.backend.jta.internal.synchronization.SynchronizationCallbackTarget.isActive. Is this transaction still active?
public boolean	isJoined() Implements org.hibernate.resource.transaction.spi.TransactionCoordinator.isJoined. Determine if there is an active transaction that this coordinator is already joined to.
public boolean	isJtaTransactionCurrentlyActive()
public boolean	Returns: `true` indicates that a RegisteredSynchronization is currently registered for this coordinator; `false` indicates it is not (yet) registered. isSynchronizationRegistered() Is the RegisteredSynchronization used by Hibernate for unified JTA Synchronization callbacks registered for this coordinator?
private void	joinJtaTransaction() Join to the JTA transaction.
private JtaTransactionCoordinatorImpl.TransactionDriverControlImpl	makePhysicalTransactionDelegate()
private JtaTransactionAdapter	makeTransactionManagerAdapter()
private JtaTransactionAdapter	makeUserTransactionAdapter()
private Iterable<TransactionObserver>	Returns: TransactionObserver observers() Needed because while iterating the observers list and executing the before/update callbacks, some observers might get removed from the list.
public void	pulse() Implements org.hibernate.resource.transaction.spi.TransactionCoordinator.pulse. Used by owner of the JdbcSession as a means to indicate that implicit joining should be done if needed.
public void	removeObserver(TransactionObserver The observer to remove. observer) Implements org.hibernate.resource.transaction.spi.TransactionCoordinator.removeObserver. Removed an observer from the coordinator.
public void	setTimeOut(int seconds) Implements org.hibernate.resource.transaction.spi.TransactionCoordinator.setTimeOut.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

autoJoinTransactions	back to summary
private final boolean autoJoinTransactions

callbackCoordinator	back to summary
private SynchronizationCallbackCoordinator callbackCoordinator

jtaPlatform	back to summary
private final JtaPlatform jtaPlatform

log	back to summary
private static final Logger log

observers	back to summary
private transient List<TransactionObserver> observers

performJtaThreadTracking	back to summary
private final boolean performJtaThreadTracking

physicalTransactionDelegate	back to summary
private JtaTransactionCoordinatorImpl.TransactionDriverControlImpl physicalTransactionDelegate

preferUserTransactions	back to summary
private final boolean preferUserTransactions

synchronizationRegistered	back to summary
private boolean synchronizationRegistered

synchronizationRegistry	back to summary
private final SynchronizationRegistryStandardImpl synchronizationRegistry

timeOut	back to summary
private int timeOut

transactionCoordinatorBuilder	back to summary
private final TransactionCoordinatorBuilder transactionCoordinatorBuilder

transactionCoordinatorOwner	back to summary
private final TransactionCoordinatorOwner transactionCoordinatorOwner

Constructor Detail

JtaTransactionCoordinatorImpl	back to summary
pack-priv JtaTransactionCoordinatorImpl(TransactionCoordinatorBuilder transactionCoordinatorBuilder, TransactionCoordinatorOwner owner, boolean autoJoinTransactions, JtaPlatform jtaPlatform) Construct a JtaTransactionCoordinatorImpl instance. package-protected to ensure access goes through builder. Parameters owner:TransactionCoordinatorOwner The transactionCoordinatorOwner autoJoinTransactions:boolean Should JTA transactions be auto-joined? Or should we wait for explicit join calls?

JtaTransactionCoordinatorImpl

back to summary

pack-priv JtaTransactionCoordinatorImpl(TransactionCoordinatorBuilder transactionCoordinatorBuilder, TransactionCoordinatorOwner owner, boolean autoJoinTransactions, JtaPlatform jtaPlatform)

Construct a JtaTransactionCoordinatorImpl instance. package-protected to ensure access goes through builder.

Parameters

owner:TransactionCoordinatorOwner: The transactionCoordinatorOwner
autoJoinTransactions:boolean: Should JTA transactions be auto-joined? Or should we wait for explicit join calls?

JtaTransactionCoordinatorImpl	back to summary
public JtaTransactionCoordinatorImpl(TransactionCoordinatorBuilder transactionCoordinatorBuilder, TransactionCoordinatorOwner owner, boolean autoJoinTransactions, JtaPlatform jtaPlatform, boolean preferUserTransactions, boolean performJtaThreadTracking, TransactionObserver... observers)

Method Detail

addObserver	back to summary
public void addObserver(TransactionObserver observer) Implements org.hibernate.resource.transaction.spi.TransactionCoordinator.addObserver. Doc from org.hibernate.resource.transaction.spi.TransactionCoordinator.addObserver. Adds an observer to the coordinator. observers are not to be cleared on transaction completion. Parameters observer:TransactionObserver The observer to add.

addObserver

back to summary

public void addObserver(TransactionObserver observer)

Implements org.hibernate.resource.transaction.spi.TransactionCoordinator.addObserver.

Doc from org.hibernate.resource.transaction.spi.TransactionCoordinator.addObserver.

Adds an observer to the coordinator.

observers are not to be cleared on transaction completion.

Parameters

observer:TransactionObserver: The observer to add.

afterCompletion	back to summary
public void afterCompletion(boolean successful, boolean delayed) Implements org.hibernate.resource.transaction.backend.jta.internal.synchronization.SynchronizationCallbackTarget.afterCompletion. Doc from org.hibernate.resource.transaction.backend.jta.internal.synchronization.SynchronizationCallbackTarget.afterCompletion. Callback of after-completion. Parameters successful:boolean Was the transaction successful? Annotations @Override

afterCompletion

back to summary

public void afterCompletion(boolean successful, boolean delayed)

Implements org.hibernate.resource.transaction.backend.jta.internal.synchronization.SynchronizationCallbackTarget.afterCompletion.

Doc from org.hibernate.resource.transaction.backend.jta.internal.synchronization.SynchronizationCallbackTarget.afterCompletion.

Callback of after-completion.

Parameters

successful:boolean: Was the transaction successful?

Annotations

@Override

beforeCompletion	back to summary
public void beforeCompletion() Implements org.hibernate.resource.transaction.backend.jta.internal.synchronization.SynchronizationCallbackTarget.beforeCompletion. Doc from org.hibernate.resource.transaction.backend.jta.internal.synchronization.SynchronizationCallbackTarget.beforeCompletion. Callback of before-completion. Annotations @Override

beforeCompletion

back to summary

public void beforeCompletion()

Implements org.hibernate.resource.transaction.backend.jta.internal.synchronization.SynchronizationCallbackTarget.beforeCompletion.

Doc from org.hibernate.resource.transaction.backend.jta.internal.synchronization.SynchronizationCallbackTarget.beforeCompletion.

Callback of before-completion.

Annotations

@Override

createIsolationDelegate	back to summary
public IsolationDelegate createIsolationDelegate() Implements org.hibernate.resource.transaction.spi.TransactionCoordinator.createIsolationDelegate. Doc from org.hibernate.resource.transaction.spi.TransactionCoordinator.createIsolationDelegate. Retrieve an isolation delegate appropriate for this transaction strategy. Returns:IsolationDelegate An isolation delegate. Annotations @Override

createIsolationDelegate

back to summary

public IsolationDelegate createIsolationDelegate()

Implements org.hibernate.resource.transaction.spi.TransactionCoordinator.createIsolationDelegate.

Doc from org.hibernate.resource.transaction.spi.TransactionCoordinator.createIsolationDelegate.

Retrieve an isolation delegate appropriate for this transaction strategy.

Returns:IsolationDelegate

An isolation delegate.

Annotations

@Override

explicitJoin back to summary

explicitJoin	back to summary
public void explicitJoin() Implements org.hibernate.resource.transaction.spi.TransactionCoordinator.explicitJoin. Doc from org.hibernate.resource.transaction.spi.TransactionCoordinator.explicitJoin. Indicates an explicit request to join a transaction. This is mainly intended to handle the JPA requirement around `javax.persistence.EntityManager#joinTransaction()`, and generally speaking only has an impact in JTA environments Annotations @Override

public void explicitJoin()

Implements org.hibernate.resource.transaction.spi.TransactionCoordinator.explicitJoin.

Doc from org.hibernate.resource.transaction.spi.TransactionCoordinator.explicitJoin.

Indicates an explicit request to join a transaction. This is mainly intended to handle the JPA requirement around javax.persistence.EntityManager#joinTransaction(), and generally speaking only has an impact in JTA environments

Annotations

@Override

getJpaCompliance	back to summary
public JpaCompliance getJpaCompliance() Implements org.hibernate.resource.transaction.spi.TransactionCoordinator.getJpaCompliance. Annotations @Override

getJpaCompliance

back to summary

public JpaCompliance getJpaCompliance()

Implements org.hibernate.resource.transaction.spi.TransactionCoordinator.getJpaCompliance.

Annotations

@Override

getLocalSynchronizations	back to summary
public SynchronizationRegistry getLocalSynchronizations() Implements org.hibernate.resource.transaction.spi.TransactionCoordinator.getLocalSynchronizations. Doc from org.hibernate.resource.transaction.spi.TransactionCoordinator.getLocalSynchronizations. Get access to the local registry of Synchronization instances Returns:SynchronizationRegistry The local Synchronization registry Annotations @Override

getLocalSynchronizations

back to summary

public SynchronizationRegistry getLocalSynchronizations()

Implements org.hibernate.resource.transaction.spi.TransactionCoordinator.getLocalSynchronizations.

Doc from org.hibernate.resource.transaction.spi.TransactionCoordinator.getLocalSynchronizations.

Get access to the local registry of Synchronization instances

Returns:SynchronizationRegistry

The local Synchronization registry

Annotations

@Override

getSynchronizationCallbackCoordinator	back to summary
public SynchronizationCallbackCoordinator getSynchronizationCallbackCoordinator()

getTimeOut	back to summary
public int getTimeOut() Implements org.hibernate.resource.transaction.spi.TransactionCoordinator.getTimeOut. Annotations @Override

getTimeOut

back to summary

public int getTimeOut()

Implements org.hibernate.resource.transaction.spi.TransactionCoordinator.getTimeOut.

Annotations

@Override

getTransactionCoordinatorBuilder	back to summary
public TransactionCoordinatorBuilder getTransactionCoordinatorBuilder() Implements org.hibernate.resource.transaction.spi.TransactionCoordinator.getTransactionCoordinatorBuilder. Doc from org.hibernate.resource.transaction.spi.TransactionCoordinator.getTransactionCoordinatorBuilder. Access to the builder that generated this coordinator Annotations @Override

getTransactionCoordinatorBuilder

back to summary

public TransactionCoordinatorBuilder getTransactionCoordinatorBuilder()

Implements org.hibernate.resource.transaction.spi.TransactionCoordinator.getTransactionCoordinatorBuilder.

Doc from org.hibernate.resource.transaction.spi.TransactionCoordinator.getTransactionCoordinatorBuilder.

Access to the builder that generated this coordinator

Annotations

@Override

getTransactionCoordinatorOwner	back to summary
public TransactionCoordinatorOwner getTransactionCoordinatorOwner()

getTransactionDriverControl	back to summary
public TransactionCoordinator.TransactionDriver getTransactionDriverControl() Implements org.hibernate.resource.transaction.spi.TransactionCoordinator.getTransactionDriverControl. Doc from org.hibernate.resource.transaction.spi.TransactionCoordinator.getTransactionDriverControl. Get the delegate used by the local transaction driver to control the underlying transaction Returns:TransactionCoordinator.TransactionDriver The control delegate. Annotations @Override

getTransactionDriverControl

back to summary

public TransactionCoordinator.TransactionDriver getTransactionDriverControl()

Implements org.hibernate.resource.transaction.spi.TransactionCoordinator.getTransactionDriverControl.

Doc from org.hibernate.resource.transaction.spi.TransactionCoordinator.getTransactionDriverControl.

Get the delegate used by the local transaction driver to control the underlying transaction

Returns:TransactionCoordinator.TransactionDriver

The control delegate.

Annotations

@Override

invalidate	back to summary
public void invalidate() Overrides default org.hibernate.resource.transaction.spi.TransactionCoordinator.invalidate. Annotations @Override

invalidate

back to summary

public void invalidate()

Overrides default org.hibernate.resource.transaction.spi.TransactionCoordinator.invalidate.

Annotations

@Override

isActive back to summary

isActive	back to summary
public boolean isActive() Implements org.hibernate.resource.transaction.spi.TransactionCoordinator.isActive, org.hibernate.resource.transaction.backend.jta.internal.synchronization.SynchronizationCallbackTarget.isActive. Doc from org.hibernate.resource.transaction.spi.TransactionCoordinator.isActive. 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 `java.sql.Connection`, only when it is initiated from here. Returns:boolean `true` if the transaction is still active; `false` otherwise. Annotations @Override

public boolean isActive()

Implements org.hibernate.resource.transaction.spi.TransactionCoordinator.isActive, org.hibernate.resource.transaction.backend.jta.internal.synchronization.SynchronizationCallbackTarget.isActive.

Doc from org.hibernate.resource.transaction.spi.TransactionCoordinator.isActive.

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 java.sql.Connection, only when it is initiated from here.

Returns:boolean

true if the transaction is still active; false otherwise.

Annotations

@Override

isJoined back to summary

isJoined	back to summary
public boolean isJoined() Implements org.hibernate.resource.transaction.spi.TransactionCoordinator.isJoined. Doc from org.hibernate.resource.transaction.spi.TransactionCoordinator.isJoined. Determine if there is an active transaction that this coordinator is already joined to. Returns:boolean `true` if there is an active transaction this coordinator is already joined to; `false` otherwise. Annotations @Override

public boolean isJoined()

Implements org.hibernate.resource.transaction.spi.TransactionCoordinator.isJoined.

Doc from org.hibernate.resource.transaction.spi.TransactionCoordinator.isJoined.

Determine if there is an active transaction that this coordinator is already joined to.

Returns:boolean

true if there is an active transaction this coordinator is already joined to; false otherwise.

Annotations

@Override

isJtaTransactionCurrentlyActive	back to summary
public boolean isJtaTransactionCurrentlyActive()

isSynchronizationRegistered back to summary

isSynchronizationRegistered	back to summary
public boolean isSynchronizationRegistered() Is the RegisteredSynchronization used by Hibernate for unified JTA Synchronization callbacks registered for this coordinator? Returns:boolean `true` indicates that a RegisteredSynchronization is currently registered for this coordinator; `false` indicates it is not (yet) registered.

public boolean isSynchronizationRegistered()

Is the RegisteredSynchronization used by Hibernate for unified JTA Synchronization callbacks registered for this coordinator?

Returns:boolean: true indicates that a RegisteredSynchronization is currently registered for this coordinator; false indicates it is not (yet) registered.

joinJtaTransaction	back to summary
private void joinJtaTransaction() Join to the JTA transaction. Note that the underlying meaning of joining in JTA environments is to register the RegisteredSynchronization with the JTA system

makePhysicalTransactionDelegate	back to summary
private JtaTransactionCoordinatorImpl.TransactionDriverControlImpl makePhysicalTransactionDelegate()

makeTransactionManagerAdapter	back to summary
private JtaTransactionAdapter makeTransactionManagerAdapter()

makeUserTransactionAdapter	back to summary
private JtaTransactionAdapter makeUserTransactionAdapter()

observers	back to summary
private Iterable<TransactionObserver> observers() Needed because while iterating the observers list and executing the before/update callbacks, some observers might get removed from the list. Yet try to not allocate anything for when the list is empty, as this is a common case. Returns:Iterable<TransactionObserver> TransactionObserver

observers

back to summary

private Iterable<TransactionObserver> observers()

Needed because while iterating the observers list and executing the before/update callbacks, some observers might get removed from the list. Yet try to not allocate anything for when the list is empty, as this is a common case.

Returns:Iterable<TransactionObserver>: TransactionObserver

pulse	back to summary
public void pulse() Implements org.hibernate.resource.transaction.spi.TransactionCoordinator.pulse. Doc from org.hibernate.resource.transaction.spi.TransactionCoordinator.pulse. Used by owner of the JdbcSession as a means to indicate that implicit joining should be done if needed. Annotations @Override

pulse

back to summary

public void pulse()

Implements org.hibernate.resource.transaction.spi.TransactionCoordinator.pulse.

Doc from org.hibernate.resource.transaction.spi.TransactionCoordinator.pulse.

Used by owner of the JdbcSession as a means to indicate that implicit joining should be done if needed.

Annotations

@Override

removeObserver	back to summary
public void removeObserver(TransactionObserver observer) Implements org.hibernate.resource.transaction.spi.TransactionCoordinator.removeObserver. Doc from org.hibernate.resource.transaction.spi.TransactionCoordinator.removeObserver. Removed an observer from the coordinator. Parameters observer:TransactionObserver The observer to remove. Annotations @Override

removeObserver

back to summary

public void removeObserver(TransactionObserver observer)

Implements org.hibernate.resource.transaction.spi.TransactionCoordinator.removeObserver.

Doc from org.hibernate.resource.transaction.spi.TransactionCoordinator.removeObserver.

Removed an observer from the coordinator.

Parameters

observer:TransactionObserver: The observer to remove.

Annotations

@Override

setTimeOut	back to summary
public void setTimeOut(int seconds) Implements org.hibernate.resource.transaction.spi.TransactionCoordinator.setTimeOut. Annotations @Override

setTimeOut

back to summary

public void setTimeOut(int seconds)

Implements org.hibernate.resource.transaction.spi.TransactionCoordinator.setTimeOut.

Annotations

@Override

org.hibernate.resource.transaction.backend.jta.internal back to summary

public Class JtaTransactionCoordinatorImpl.TransactionDriverControlImpl

Class Inheritance

extends Object
implements TransactionDriver

java.lang.Object
org.hibernate.resource.transaction.backend.jta.internal.JtaTransactionCoordinatorImpl.TransactionDriverControlImpl

All Implemented Interfaces

org.hibernate.resource.transaction.spi.TransactionCoordinator.TransactionDriver

Implementation of the LocalInflow for this TransactionCoordinator. Allows the local transaction (org.hibernate.Transaction to callback into this TransactionCoordinator for the purpose of driving the underlying JTA transaction.

Field Summary

Modifier and Type	Field and Description
private boolean	invalid
private final JtaTransactionAdapter	jtaTransactionAdapter

Constructor Summary

Access	Constructor and Description
public	TransactionDriverControlImpl(JtaTransactionAdapter jtaTransactionAdapter)

Method Summary

Modifier and Type	Method and Description
public void	begin() Implements org.hibernate.resource.transaction.spi.TransactionCoordinator.TransactionDriver.begin. Begin the physical transaction
public void	commit() Implements org.hibernate.resource.transaction.spi.TransactionCoordinator.TransactionDriver.commit. Commit the physical transaction
protected void	errorIfInvalid()
public TransactionStatus	getStatus() Implements org.hibernate.resource.transaction.spi.TransactionCoordinator.TransactionDriver.getStatus.
protected void	invalidate()
public void	markRollbackOnly() Implements org.hibernate.resource.transaction.spi.TransactionCoordinator.TransactionDriver.markRollbackOnly.
public void	rollback() Implements org.hibernate.resource.transaction.spi.TransactionCoordinator.TransactionDriver.rollback. Rollback the physical transaction