Package | Description |
---|---|
org.axonframework.boot.autoconfig | |
org.axonframework.commandhandling |
Classes that implement the concept of command handling using explicit command objects.
|
org.axonframework.commandhandling.disruptor | |
org.axonframework.common.transaction | |
org.axonframework.config | |
org.axonframework.eventhandling |
Classes related to event handling and dispatching, such as
Event Listeners and the Event Bus . |
org.axonframework.eventhandling.scheduling.java | |
org.axonframework.eventhandling.scheduling.quartz | |
org.axonframework.eventsourcing |
Classes related to event sourcing.
|
org.axonframework.eventsourcing.eventstore.jdbc |
JDBC Implementation of the EventStore.
|
org.axonframework.eventsourcing.eventstore.jpa |
JPA Implementation of the EventStore.
|
org.axonframework.messaging.interceptors | |
org.axonframework.queryhandling | |
org.axonframework.spring.config | |
org.axonframework.spring.eventsourcing | |
org.axonframework.spring.messaging.unitofwork |
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 |
JpaAutoConfiguration.eventStorageEngine(Serializer serializer,
PersistenceExceptionResolver persistenceExceptionResolver,
AxonConfiguration configuration,
EntityManagerProvider entityManagerProvider,
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)
Defines the Transaction Manager to use when processing Events for this Saga.
|
default Configurer |
Configurer.configureTransactionManager(Function<Configuration,TransactionManager> transactionManagerBuilder)
Configures the given Transaction Manager to use in this configuration.
|
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 . |
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 serializer,
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 serializer,
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.
|
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 serializer,
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 serializer,
EventUpcaster upcasterChain,
PersistenceExceptionResolver persistenceExceptionResolver,
Serializer eventSerializer,
EntityManagerProvider entityManagerProvider,
TransactionManager transactionManager)
Initializes an EventStorageEngine that uses JPA to store and load events.
|
JpaEventStorageEngine(Serializer serializer,
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 . |
Constructor and Description |
---|
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 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–2017. All rights reserved.