Package io.micronaut.transaction.async

Interface AsyncTransactionOperations<C>

Type Parameters:
C - The connection type
All Known Implementing Classes:
AsyncUsingReactiveTransactionOperations, AsyncUsingSyncTransactionOperations
public interface AsyncTransactionOperations<C>
An interface for async transaction management.
Since:
3.5.0

  • Method Details

    • findTransactionStatus

      default Optional<? extends AsyncTransactionStatus<?>> findTransactionStatus()
      Find optional propagated transaction status.
      Returns:
      The transaction status.

    • withTransaction

      @NonNull <T> @NonNull CompletionStage<T> withTransaction(@NonNull @NonNull TransactionDefinition definition, @NonNull @NonNull Function<AsyncTransactionStatus<C>,CompletionStage<T>> handler)
      Execute the given handler with a new transaction.
      Type Parameters:
      T - The emitted type
      Parameters:
      definition - The definition
      handler - The handler
      Returns:
      A publisher that emits the result type

    • withTransaction

      @NonNull default <T> @NonNull CompletionStage<T> withTransaction(@NonNull @NonNull Function<AsyncTransactionStatus<C>,CompletionStage<T>> handler)
      Execute the given handler with a new transaction.
      Type Parameters:
      T - The emitted type
      Parameters:
      handler - The handler
      Returns:
      A publisher that emits the result type

    • managesTransaction

      boolean managesTransaction(@NonNull @NonNull AsyncTransactionStatus<C> transactionStatus)
      Determine whether the given transaction status refers to a transaction managed by this AsyncTransactionOperations instance.
      Parameters:
      transactionStatus - The transaction status to verify
      Returns:
      true if the transaction is managed (i.e. created/supplied) by this operations instance
      Since:
      5.0