org.springframework.transaction.reactive

Class TransactionContextManager

java.lang.Object

org.springframework.transaction.reactive.TransactionContextManager

public abstract class TransactionContextManager
extends Object

Delegate to register and obtain transactional contexts.

Typically used by components that intercept or orchestrate transactional flows such as AOP interceptors or transactional operators.

Since:

5.2

Author:

Mark Paluch

See Also:

TransactionSynchronization

Method Summary

Modifier and Type	Method and Description
static Function<reactor.util.context.Context,reactor.util.context.Context>	createTransactionContext() Create a TransactionContext and register it in the subscriber Context.
static reactor.core.publisher.Mono<TransactionContext>	currentContext() Obtain the current TransactionContext from the subscriber context or the transactional context holder.
static Function<reactor.util.context.Context,reactor.util.context.Context>	getOrCreateContext() Return a Function to create or associate a new TransactionContext.
static Function<reactor.util.context.Context,reactor.util.context.Context>	getOrCreateContextHolder() Return a Function to create or associate a new TransactionContextHolder.

Methods inherited from class java.lang.Object

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

Method Detail

currentContext

public static reactor.core.publisher.Mono<TransactionContext> currentContext()
                                                                      throws NoTransactionException

Obtain the current TransactionContext from the subscriber context or the transactional context holder. Context retrieval fails with NoTransactionException if no context or context holder is registered.

Returns:

the current TransactionContext

Throws:

NoTransactionException - if no TransactionContext was found in the subscriber context or no context found in a holder

createTransactionContext

public static Function<reactor.util.context.Context,reactor.util.context.Context> createTransactionContext()

Create a TransactionContext and register it in the subscriber Context.

Returns:

functional context registration.

Throws:

IllegalStateException - if a transaction context is already associated.

See Also:

Mono.contextWrite(Function), Flux.contextWrite(Function)

getOrCreateContext

public static Function<reactor.util.context.Context,reactor.util.context.Context> getOrCreateContext()

Return a Function to create or associate a new TransactionContext. Interaction with transactional resources through TransactionSynchronizationManager requires a TransactionContext to be registered in the subscriber context.

Returns:

functional context registration.

getOrCreateContextHolder

public static Function<reactor.util.context.Context,reactor.util.context.Context> getOrCreateContextHolder()

Return a Function to create or associate a new TransactionContextHolder. Creation and release of transactions within a reactive flow requires a mutable holder that follows a top to down execution scheme. Reactor's subscriber context follows a down to top approach regarding mutation visibility.

Returns:

functional context registration.