Package org.axonframework.eventsourcing.eventstore.jpa

Class JpaTransactionalExecutorProvider

java.lang.Object

org.axonframework.eventsourcing.eventstore.jpa.JpaTransactionalExecutorProvider

All Implemented Interfaces:

TransactionalExecutorProvider<jakarta.persistence.EntityManager>

@Internal
public class JpaTransactionalExecutorProvider
extends Object
implements TransactionalExecutorProvider<jakarta.persistence.EntityManager>

A TransactionalExecutorProvider implementation for JPA EntityManagers which provides a TransactionalExecutor.

When a processing context is supplied, supplies the TransactionalExecutor it must contain. If no processing context is supplied, creates an executor that executes the supplied functions in their own transaction.

Since:

5.0.2

Author:

John Hendrikx

Field Summary

Fields

Modifier and Type	Field	Description
static final Context.ResourceKey<Supplier<EntityManagerExecutor>>	SUPPLIER_KEY	The resource key for the EntityManagerExecutor supplier.

Constructor Summary

Constructors

Constructor	Description
JpaTransactionalExecutorProvider(jakarta.persistence.EntityManagerFactory entityManagerFactory)	Constructs a new instance.

Method Summary

Modifier and Type	Method	Description
TransactionalExecutor<jakarta.persistence.EntityManager>	getTransactionalExecutor(ProcessingContext processingContext)	Provides a TransactionalExecutor, using the optional processing context.

Methods inherited from class java.lang.Object

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

Field Details

SUPPLIER_KEY

public static final Context.ResourceKey<Supplier<EntityManagerExecutor>> SUPPLIER_KEY

The resource key for the EntityManagerExecutor supplier.

Constructor Details

JpaTransactionalExecutorProvider

public JpaTransactionalExecutorProvider(@Nonnull
 jakarta.persistence.EntityManagerFactory entityManagerFactory)

Constructs a new instance.

Parameters:

entityManagerFactory - A factory constructing an EntityManager used when no processing context is supplied.

Method Details

getTransactionalExecutor

public TransactionalExecutor<jakarta.persistence.EntityManager> getTransactionalExecutor(@Nullable
 ProcessingContext processingContext)

Description copied from interface: TransactionalExecutorProvider

Provides a TransactionalExecutor, using the optional processing context.

Specified by:

getTransactionalExecutor in interface TransactionalExecutorProvider<jakarta.persistence.EntityManager>

Parameters:

processingContext - A ProcessingContext, can be null.

Returns:

A TransactionalExecutor, never null.