Package io.micronaut.transaction.support

Class AbstractPropagatedStatusTransactionOperations<T extends TransactionStatus<C>,C>

java.lang.Object

io.micronaut.transaction.support.AbstractPropagatedStatusTransactionOperations<T,C>

Type Parameters:

T - The transaction type

C - The connection type

All Implemented Interfaces:

TransactionOperations<C>

Direct Known Subclasses:

AbstractSpringTransactionOperations, AbstractTransactionOperations

public abstract class AbstractPropagatedStatusTransactionOperations<T extends TransactionStatus<C>,C>
extends Object
implements TransactionOperations<C>

Abstract transaction operations that propagates the status in the propagated context.

Since:

4.0.0

Author:

Denis Stepanov

Constructor Summary

Constructors

Constructor	Description
AbstractPropagatedStatusTransactionOperations()

Method Summary

Modifier and Type	Method	Description
protected abstract <R> R	doExecute(TransactionDefinition definition, TransactionCallback<C,R> callback)	Do execute in transaction.
final <R> R	execute(@NonNull TransactionDefinition definition, @NonNull TransactionCallback<C,R> callback)	Execute a transaction within the context of the function.
final Optional<TransactionStatus<C>>	findTransactionStatus()	Find optional propagated transaction status.
final Optional<T>	findTransactionStatusInternal()

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.micronaut.transaction.TransactionOperations

executeRead, executeWrite, getConnection, hasConnection, managesTransaction

Constructor Details

AbstractPropagatedStatusTransactionOperations

public AbstractPropagatedStatusTransactionOperations()

Method Details

doExecute

protected abstract <R> R doExecute(TransactionDefinition definition,
 TransactionCallback<C,R> callback)

Do execute in transaction.

Type Parameters:

R - The result type

Parameters:

definition - The transaction definition

callback - The callback

Returns:

The result

findTransactionStatus

public final Optional<TransactionStatus<C>> findTransactionStatus()

Description copied from interface: TransactionOperations

Find optional propagated transaction status.

Specified by:

findTransactionStatus in interface TransactionOperations<T extends TransactionStatus<C>>

Returns:

The transaction status.

findTransactionStatusInternal

public final Optional<T> findTransactionStatusInternal()

execute

public final <R> R execute(@NonNull
 @NonNull TransactionDefinition definition,
 @NonNull
 @NonNull TransactionCallback<C,R> callback)

Description copied from interface: TransactionOperations

Execute a transaction within the context of the function.

Specified by:

execute in interface TransactionOperations<T extends TransactionStatus<C>>

Type Parameters:

R - The result

Parameters:

definition - The transaction definition

callback - The call back

Returns:

The result