Modifier and Type | Method and Description |
---|---|
TransactionManager |
NoOpTransactionAutoConfiguration.axonTransactionManager() |
TransactionManager |
TransactionAutoConfiguration.axonTransactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager) |
Modifier and Type | Method and Description |
---|---|
SimpleCommandBus |
AxonAutoConfiguration.commandBus(TransactionManager txManager,
AxonConfiguration axonConfiguration) |
EventStorageEngine |
JdbcAutoConfiguration.eventStorageEngine(Serializer serializer,
PersistenceExceptionResolver persistenceExceptionResolver,
Serializer eventSerializer,
AxonConfiguration configuration,
ConnectionProvider connectionProvider,
TransactionManager transactionManager) |
EventStorageEngine |
JpaAutoConfiguration.eventStorageEngine(Serializer serializer,
PersistenceExceptionResolver persistenceExceptionResolver,
Serializer eventSerializer,
AxonConfiguration configuration,
EntityManagerProvider entityManagerProvider,
TransactionManager transactionManager) |
SimpleQueryBus |
AxonAutoConfiguration.queryBus(AxonConfiguration axonConfiguration,
TransactionManager transactionManager) |
SimpleQueryBus |
AxonAutoConfiguration.queryBus(AxonConfiguration axonConfiguration,
TransactionManager transactionManager,
QueryInvocationErrorHandler eh) |
Constructor and Description |
---|
AsynchronousCommandBus(Executor executor,
TransactionManager transactionManager,
MessageMonitor<? super CommandMessage<?>> messageMonitor)
Initialize the AsynchronousCommandBus using the given
executor , transactionManager and
messageMonitor . |
SimpleCommandBus(TransactionManager transactionManager,
MessageMonitor<? super CommandMessage<?>> messageMonitor)
Initializes the SimpleCommandBus with the given
transactionManager and messageMonitor |
Modifier and Type | Method and Description |
---|---|
TransactionManager |
DisruptorConfiguration.getTransactionManager()
Returns the transaction manager to use to manage a transaction around the storage and publication of events.
|
Modifier and Type | Method and Description |
---|---|
DisruptorConfiguration |
DisruptorConfiguration.setTransactionManager(TransactionManager newTransactionManager)
Sets the transaction manager to use to manage a transaction around the storage and publication of events.
|
Constructor and Description |
---|
EventPublisher(Executor executor,
TransactionManager transactionManager,
RollbackConfiguration rollbackConfiguration,
int segmentId)
Initializes the EventPublisher to publish Events to the given
eventStore and eventBus
for aggregate of given aggregateType . |
Modifier and Type | Class and Description |
---|---|
class |
NoTransactionManager
TransactionManager implementation that does nothing.
|
Modifier and Type | Method and Description |
---|---|
static TransactionManager |
NoTransactionManager.instance()
Returns the singleton instance of this TransactionManager
|
Modifier and Type | Method and Description |
---|---|
static Configurer |
DefaultConfigurer.jpaConfiguration(EntityManagerProvider entityManagerProvider,
TransactionManager transactionManager)
Returns a Configurer instance which has JPA versions of building blocks configured, such as a JPA based Event
Store (see
JpaEventStorageEngine ), a JpaTokenStore and JpaSagaStore . |
Modifier and Type | Method and Description |
---|---|
SagaConfiguration<S> |
SagaConfiguration.configureTransactionManager(Function<Configuration,TransactionManager> transactionManager)
Deprecated.
|
default Configurer |
Configurer.configureTransactionManager(Function<Configuration,TransactionManager> transactionManagerBuilder)
Configures the given Transaction Manager to use in this configuration.
|
EventProcessingConfiguration |
EventProcessingConfiguration.configureTransactionManager(String name,
Function<Configuration,TransactionManager> transactionManagerBuilder)
|
Constructor and Description |
---|
SimpleDeadlineManager(ScopeAwareProvider scopeAwareProvider,
ScheduledExecutorService scheduledExecutorService,
TransactionManager transactionManager)
Initializes a SimpleDeadlineManager to handle the process around scheduling and triggering a
DeadlineMessage |
SimpleDeadlineManager(ScopeAwareProvider scopeAwareProvider,
TransactionManager transactionManager)
Initializes SimpleDeadlineManager with
transactionManager and scopeAwareProvider which will
load and send messages to Scope implementing components. |
Constructor and Description |
---|
QuartzDeadlineManager(org.quartz.Scheduler scheduler,
ScopeAwareProvider scopeAwareProvider,
TransactionManager transactionManager)
Initializes QuartzDeadlineManager with given
scheduler and scopeAwareProvider which will load
and send messages to Scope implementing components. |
QuartzDeadlineManager(org.quartz.Scheduler scheduler,
ScopeAwareProvider scopeAwareProvider,
TransactionManager transactionManager,
Serializer serializer)
Initializes QuartzDeadlineManager with given
scheduler and scopeAwareProvider which will load
and send messages to Scope implementing components. |
Constructor and Description |
---|
TrackingEventProcessor(String name,
EventHandlerInvoker eventHandlerInvoker,
StreamableMessageSource<TrackedEventMessage<?>> messageSource,
TokenStore tokenStore,
TransactionManager transactionManager)
Initializes an EventProcessor with given
name that subscribes to the given messageSource for
events. |
TrackingEventProcessor(String name,
EventHandlerInvoker eventHandlerInvoker,
StreamableMessageSource<TrackedEventMessage<?>> messageSource,
TokenStore tokenStore,
TransactionManager transactionManager,
MessageMonitor<? super EventMessage<?>> messageMonitor)
Initializes an EventProcessor with given
name that subscribes to the given messageSource for
events. |
TrackingEventProcessor(String name,
EventHandlerInvoker eventHandlerInvoker,
StreamableMessageSource<TrackedEventMessage<?>> messageSource,
TokenStore tokenStore,
TransactionManager transactionManager,
MessageMonitor<? super EventMessage<?>> messageMonitor,
RollbackConfiguration rollbackConfiguration,
ErrorHandler errorHandler,
TrackingEventProcessorConfiguration config)
Initializes an EventProcessor with given
name that subscribes to the given messageSource for
events. |
Constructor and Description |
---|
SimpleEventScheduler(ScheduledExecutorService executorService,
EventBus eventBus,
TransactionManager transactionManager)
Initialize the SimpleEventScheduler using the given
executorService as trigger and execution
mechanism, and publishes events to the given eventBus . |
Modifier and Type | Method and Description |
---|---|
void |
QuartzEventScheduler.setTransactionManager(TransactionManager transactionManager)
Sets the transaction manager that manages a transaction around the publication of an event.
|
Constructor and Description |
---|
AbstractSnapshotter(EventStore eventStore,
Executor executor,
TransactionManager transactionManager)
Initializes the Snapshotter to append snapshots in the given
eventStore . |
AbstractSnapshotter(EventStore eventStore,
TransactionManager transactionManager)
Initializes the Snapshotter to append snapshots in the given
eventStore . |
AggregateSnapshotter(EventStore eventStore,
List<AggregateFactory<?>> aggregateFactories,
ParameterResolverFactory parameterResolverFactory,
Executor executor,
TransactionManager transactionManager)
Initializes a snapshotter that stores snapshots using the given
executor . |
AggregateSnapshotter(EventStore eventStore,
List<AggregateFactory<?>> aggregateFactories,
ParameterResolverFactory parameterResolverFactory,
HandlerDefinition handlerDefinition,
Executor executor,
TransactionManager transactionManager,
RepositoryProvider repositoryProvider)
Initializes a snapshotter that stores snapshots using the given
executor . |
Constructor and Description |
---|
JdbcEventStorageEngine(ConnectionProvider connectionProvider,
TransactionManager transactionManager)
Initializes an EventStorageEngine that uses JDBC to store and load events using the default
EventSchema . |
JdbcEventStorageEngine(Serializer serializer,
EventUpcaster upcasterChain,
PersistenceExceptionResolver persistenceExceptionResolver,
ConnectionProvider connectionProvider,
TransactionManager transactionManager)
Initializes an EventStorageEngine that uses JDBC to store and load events using the default
EventSchema . |
JdbcEventStorageEngine(Serializer snapshotSerializer,
EventUpcaster upcasterChain,
PersistenceExceptionResolver persistenceExceptionResolver,
Serializer eventSerializer,
ConnectionProvider connectionProvider,
TransactionManager transactionManager)
Initializes an EventStorageEngine that uses JDBC to store and load events using the default
EventSchema . |
JdbcEventStorageEngine(Serializer snapshotSerializer,
EventUpcaster upcasterChain,
PersistenceExceptionResolver persistenceExceptionResolver,
Serializer eventSerializer,
Integer batchSize,
ConnectionProvider connectionProvider,
TransactionManager transactionManager,
Class<?> dataType,
EventSchema schema,
Integer maxGapOffset,
Long lowestGlobalSequence)
Initializes an EventStorageEngine that uses JDBC to store and load events.
|
JdbcEventStorageEngine(Serializer snapshotSerializer,
EventUpcaster upcasterChain,
PersistenceExceptionResolver persistenceExceptionResolver,
Serializer eventSerializer,
Predicate<? super DomainEventData<?>> snapshotFilter,
Integer batchSize,
ConnectionProvider connectionProvider,
TransactionManager transactionManager,
Class<?> dataType,
EventSchema schema,
Integer maxGapOffset,
Long lowestGlobalSequence)
Initializes an EventStorageEngine that uses JDBC to store and load events.
|
Constructor and Description |
---|
JpaEventStorageEngine(EntityManagerProvider entityManagerProvider,
TransactionManager transactionManager)
Initializes an EventStorageEngine that uses JPA to store and load events.
|
JpaEventStorageEngine(Serializer serializer,
EventUpcaster upcasterChain,
DataSource dataSource,
EntityManagerProvider entityManagerProvider,
TransactionManager transactionManager)
Initializes an EventStorageEngine that uses JPA to store and load events.
|
JpaEventStorageEngine(Serializer snapshotSerializer,
EventUpcaster upcasterChain,
DataSource dataSource,
Serializer eventSerializer,
EntityManagerProvider entityManagerProvider,
TransactionManager transactionManager)
Initializes an EventStorageEngine that uses JPA to store and load events.
|
JpaEventStorageEngine(Serializer serializer,
EventUpcaster upcasterChain,
PersistenceExceptionResolver persistenceExceptionResolver,
EntityManagerProvider entityManagerProvider,
TransactionManager transactionManager)
Initializes an EventStorageEngine that uses JPA to store and load events.
|
JpaEventStorageEngine(Serializer snapshotSerializer,
EventUpcaster upcasterChain,
PersistenceExceptionResolver persistenceExceptionResolver,
Serializer eventSerializer,
EntityManagerProvider entityManagerProvider,
TransactionManager transactionManager)
Initializes an EventStorageEngine that uses JPA to store and load events.
|
JpaEventStorageEngine(Serializer snapshotSerializer,
EventUpcaster upcasterChain,
PersistenceExceptionResolver persistenceExceptionResolver,
Serializer eventSerializer,
Integer batchSize,
EntityManagerProvider entityManagerProvider,
TransactionManager transactionManager,
Long lowestGlobalSequence,
Integer maxGapOffset,
boolean explicitFlush)
Initializes an EventStorageEngine that uses JPA to store and load events.
|
Constructor and Description |
---|
TransactionManagingInterceptor(TransactionManager transactionManager)
Initializes a
TransactionManagingInterceptor that uses the given transactionManager . |
Modifier and Type | Method and Description |
---|---|
default void |
UnitOfWork.attachTransaction(TransactionManager transactionManager)
Attach a transaction to this Unit of Work, using the given
transactionManager . |
Constructor and Description |
---|
SimpleQueryBus(MessageMonitor<? super QueryMessage<?,?>> messageMonitor,
MessageMonitor<? super SubscriptionQueryUpdateMessage<?>> updateMessageMonitor,
TransactionManager transactionManager,
QueryInvocationErrorHandler errorHandler)
Initialize the query bus with the given
messageMonitor , updateMessageMonitor , transactionManager and given errorHandler . |
SimpleQueryBus(MessageMonitor<? super QueryMessage<?,?>> messageMonitor,
TransactionManager transactionManager,
QueryInvocationErrorHandler errorHandler)
Initialize the query bus with the given
messageMonitor and given errorHandler . |
SimpleQueryBus(TransactionManager transactionManager)
Initialize the query bus using given
transactionManager to manage transactions around query execution
with. |
Modifier and Type | Method and Description |
---|---|
TransactionManager |
TransactionManagerFactoryBean.getObject() |
Constructor and Description |
---|
SpringAggregateSnapshotter(EventStore eventStore,
ParameterResolverFactory parameterResolverFactory,
Executor executor,
TransactionManager txManager)
Initializes a snapshotter.
|
SpringAggregateSnapshotter(EventStore eventStore,
ParameterResolverFactory parameterResolverFactory,
HandlerDefinition handlerDefinition,
Executor executor,
TransactionManager txManager,
RepositoryProvider repositoryProvider)
Initializes a snapshotter using the ParameterResolverFactory instances available on the classpath.
|
Modifier and Type | Class and Description |
---|---|
class |
SpringTransactionManager
TransactionManager implementation that uses a
PlatformTransactionManager as
underlying transaction manager. |
Copyright © 2010–2018. All rights reserved.