io.micronaut.transaction.support

Class TransactionSynchronizationUtils

java.lang.Object

io.micronaut.transaction.support.TransactionSynchronizationUtils

@Internal
public abstract class TransactionSynchronizationUtils
extends java.lang.Object

Utility methods for triggering specific TransactionSynchronization callback methods on all currently registered synchronizations.

Since:

1.0

Author:

Juergen Hoeller, graemerocher

See Also:

TransactionSynchronization, TransactionSynchronizationManager.getSynchronizations()

Constructor Summary

Constructors

Constructor and Description
TransactionSynchronizationUtils()

Method Summary

Modifier and Type	Method and Description
static void	invokeAfterCommit(java.util.List<TransactionSynchronization> synchronizations) Actually invoke the afterCommit methods of the given Spring TransactionSynchronization objects.
static void	invokeAfterCompletion(java.util.List<TransactionSynchronization> synchronizations, TransactionSynchronization.Status completionStatus) Actually invoke the afterCompletion methods of the given Spring TransactionSynchronization objects.
static boolean	sameResourceFactory(ResourceTransactionManager tm, java.lang.Object resourceFactory) Check whether the given resource transaction managers refers to the given (underlying) resource factory.
static void	triggerAfterCommit(SynchronousTransactionState state) Trigger afterCommit callbacks on all currently registered synchronizations.
static void	triggerAfterCompletion(SynchronousTransactionState state, TransactionSynchronization.Status completionStatus) Trigger afterCompletion callbacks on all currently registered synchronizations.
static void	triggerBeforeCommit(SynchronousTransactionState state, boolean readOnly) Trigger beforeCommit callbacks on all currently registered synchronizations.
static void	triggerBeforeCompletion(SynchronousTransactionState state) Trigger beforeCompletion callbacks on all currently registered synchronizations.
static void	triggerFlush(SynchronousTransactionState state) Trigger flush callbacks on all currently registered synchronizations.

Methods inherited from class java.lang.Object

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

Constructor Detail

TransactionSynchronizationUtils

public TransactionSynchronizationUtils()

Method Detail

sameResourceFactory

public static boolean sameResourceFactory(ResourceTransactionManager tm,
                                          java.lang.Object resourceFactory)

Check whether the given resource transaction managers refers to the given (underlying) resource factory.

Parameters:

tm - the resource manager

resourceFactory - The resource factory

Returns:

True if the factories are the same

See Also:

ResourceTransactionManager.getResourceFactory()

triggerFlush

public static void triggerFlush(SynchronousTransactionState state)

Trigger flush callbacks on all currently registered synchronizations.

Parameters:

state - The transaction state

Throws:

java.lang.RuntimeException - if thrown by a flush callback

See Also:

TransactionSynchronization.flush()

triggerBeforeCommit

public static void triggerBeforeCommit(SynchronousTransactionState state,
                                       boolean readOnly)

Trigger beforeCommit callbacks on all currently registered synchronizations.

Parameters:

state - The transaction state

readOnly - whether the transaction is defined as read-only transaction

Throws:

java.lang.RuntimeException - if thrown by a beforeCommit callback

See Also:

TransactionSynchronization.beforeCommit(boolean)

triggerBeforeCompletion

public static void triggerBeforeCompletion(SynchronousTransactionState state)

Trigger beforeCompletion callbacks on all currently registered synchronizations.

Parameters:

state - The transaction state

See Also:

TransactionSynchronization.beforeCompletion()

triggerAfterCommit

public static void triggerAfterCommit(SynchronousTransactionState state)

Trigger afterCommit callbacks on all currently registered synchronizations.

Parameters:

state - The transaction state

Throws:

java.lang.RuntimeException - if thrown by a afterCommit callback

See Also:

SynchronousTransactionState.getSynchronizations(), TransactionSynchronization.afterCommit()

invokeAfterCommit

public static void invokeAfterCommit(@Nullable
                                     java.util.List<TransactionSynchronization> synchronizations)

Actually invoke the afterCommit methods of the given Spring TransactionSynchronization objects.

Parameters:

synchronizations - a List of TransactionSynchronization objects

See Also:

TransactionSynchronization.afterCommit()

triggerAfterCompletion

public static void triggerAfterCompletion(SynchronousTransactionState state,
                                          @NonNull
                                          TransactionSynchronization.Status completionStatus)

Trigger afterCompletion callbacks on all currently registered synchronizations.

Parameters:

state - The transaction state

completionStatus - the completion status according to the constants in the TransactionSynchronization interface

See Also:

SynchronousTransactionState.getSynchronizations(), TransactionSynchronization.afterCompletion(TransactionSynchronization.Status), TransactionSynchronization.Status.COMMITTED, TransactionSynchronization.Status.ROLLED_BACK, TransactionSynchronization.Status.UNKNOWN

invokeAfterCompletion

public static void invokeAfterCompletion(@Nullable
                                         java.util.List<TransactionSynchronization> synchronizations,
                                         @NonNull
                                         TransactionSynchronization.Status completionStatus)

Actually invoke the afterCompletion methods of the given Spring TransactionSynchronization objects.

Parameters:

synchronizations - a List of TransactionSynchronization objects

completionStatus - the completion status according to the constants in the TransactionSynchronization interface

See Also:

TransactionSynchronization.afterCompletion(TransactionSynchronization.Status), TransactionSynchronization.Status.COMMITTED, TransactionSynchronization.Status.ROLLED_BACK, TransactionSynchronization.Status.UNKNOWN