Package io.micronaut.transaction.sync

Class SynchronousTransactionOperationsFromReactiveTransactionOperations<T>

java.lang.Object

io.micronaut.transaction.sync.SynchronousTransactionOperationsFromReactiveTransactionOperations<T>

Type Parameters:

T - The connection type

All Implemented Interfaces:

TransactionOperations<T>

@Internal
public final class SynchronousTransactionOperationsFromReactiveTransactionOperations<T>
extends Object
implements TransactionOperations<T>

Implementation of the synchronous transaction operations using a reactive transaction operations.

Since:

3.5.0

Author:

Denis Stepanov

Constructor Summary

Constructors

Constructor	Description
SynchronousTransactionOperationsFromReactiveTransactionOperations(ReactorReactiveTransactionOperations<T> reactiveTransactionOperations, ExecutorService blockingExecutorService)

Method Summary

Modifier and Type	Method	Description
<R> R	execute(TransactionDefinition definition, TransactionCallback<T,R> callback)	Execute a transaction within the context of the function.
Optional<TransactionStatus<T>>	findTransactionStatus()	Find optional propagated transaction status.
T	getConnection()	Obtains the connection for the current transaction.
boolean	hasConnection()	Check if the connection exists.
boolean	managesTransaction(TransactionStatus<T> transactionStatus)	Determine whether the given transaction status refers to a transaction managed by this TransactionOperations instance.

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

Constructor Details

SynchronousTransactionOperationsFromReactiveTransactionOperations

public SynchronousTransactionOperationsFromReactiveTransactionOperations(ReactorReactiveTransactionOperations<T> reactiveTransactionOperations,
 ExecutorService blockingExecutorService)

Method Details

getConnection

public T getConnection()

Description copied from interface: TransactionOperations

Obtains the connection for the current transaction.

Specified by:

getConnection in interface TransactionOperations<T>

Returns:

The connection

hasConnection

public boolean hasConnection()

Description copied from interface: TransactionOperations

Check if the connection exists.

Specified by:

hasConnection in interface TransactionOperations<T>

Returns:

True if transaction exists

findTransactionStatus

public Optional<TransactionStatus<T>> findTransactionStatus()

Description copied from interface: TransactionOperations

Find optional propagated transaction status.

Specified by:

findTransactionStatus in interface TransactionOperations<T>

Returns:

The transaction status.

execute

public <R> R execute(TransactionDefinition definition,
 TransactionCallback<T,R> callback)

Description copied from interface: TransactionOperations

Execute a transaction within the context of the function.

Specified by:

execute in interface TransactionOperations<T>

Type Parameters:

R - The result

Parameters:

definition - The transaction definition

callback - The call back

Returns:

The result

managesTransaction

public boolean managesTransaction(TransactionStatus<T> transactionStatus)

Description copied from interface: TransactionOperations

Determine whether the given transaction status refers to a transaction managed by this TransactionOperations instance.

Specified by:

managesTransaction in interface TransactionOperations<T>

Parameters:

transactionStatus - The transaction status to verify

Returns:

true if the transaction is managed (i.e. created/supplied) by this operations instance