Package org.axonframework.eventsourcing.eventstore.jdbc

Class JdbcTransactionalExecutorProvider

java.lang.Object

org.axonframework.eventsourcing.eventstore.jdbc.JdbcTransactionalExecutorProvider

All Implemented Interfaces:

TransactionalExecutorProvider<Connection>

@Internal
public class JdbcTransactionalExecutorProvider
extends Object
implements TransactionalExecutorProvider<Connection>

A TransactionalExecutorProvider implementation for JDBC Connections 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<ConnectionExecutor>>	SUPPLIER_KEY	The resource key for the ConnectionExecutor supplier.

Constructor Summary

Constructors

Constructor	Description
JdbcTransactionalExecutorProvider(DataSource dataSource)	Constructs a new instance.

Method Summary

Modifier and Type	Method	Description
TransactionalExecutor<Connection>	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<ConnectionExecutor>> SUPPLIER_KEY

The resource key for the ConnectionExecutor supplier.

Constructor Details

JdbcTransactionalExecutorProvider

public JdbcTransactionalExecutorProvider(@Nonnull
 DataSource dataSource)

Constructs a new instance.

Parameters:

dataSource - A JDBC DataSource used when no processing context is supplied, cannot be null.

Method Details

getTransactionalExecutor

public TransactionalExecutor<Connection> getTransactionalExecutor(@Nullable
 ProcessingContext processingContext)

Description copied from interface: TransactionalExecutorProvider

Provides a TransactionalExecutor, using the optional processing context.

Specified by:

getTransactionalExecutor in interface TransactionalExecutorProvider<Connection>

Parameters:

processingContext - A ProcessingContext, can be null.

Returns:

A TransactionalExecutor, never null.