Package | Description |
---|---|
org.axonframework.commandhandling |
Classes that implement the concept of command handling using explicit command objects.
|
org.axonframework.commandhandling.disruptor | |
org.axonframework.config | |
org.axonframework.eventhandling |
Classes related to event handling and dispatching, such as
Event Listeners and the Event Bus . |
org.axonframework.messaging.unitofwork |
Modifier and Type | Method and Description |
---|---|
void |
SimpleCommandBus.setRollbackConfiguration(RollbackConfiguration rollbackConfiguration)
Sets the RollbackConfiguration that allows you to change when the UnitOfWork is committed.
|
Modifier and Type | Method and Description |
---|---|
RollbackConfiguration |
DisruptorConfiguration.getRollbackConfiguration()
Returns the RollbackConfiguration indicating for which Exceptions the DisruptorCommandBus should perform a
rollback, and which exceptions should result in a Commit.
|
Modifier and Type | Method and Description |
---|---|
<R> R |
DisruptorUnitOfWork.executeWithResult(Callable<R> task,
RollbackConfiguration rollbackConfiguration)
Execute the given
task in the context of this Unit of Work. |
DisruptorConfiguration |
DisruptorConfiguration.setRollbackConfiguration(RollbackConfiguration rollbackConfiguration)
Sets the rollback configuration for the DisruptorCommandBus to use.
|
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 | Method and Description |
---|---|
SagaConfiguration<S> |
SagaConfiguration.configureRollbackConfiguration(Function<Configuration,RollbackConfiguration> rollbackConfiguration)
Defines the policy to roll back or commit a Unit of Work in case exceptions occur.
|
Constructor and Description |
---|
AbstractEventProcessor(String name,
EventHandlerInvoker eventHandlerInvoker,
RollbackConfiguration rollbackConfiguration,
ErrorHandler errorHandler,
MessageMonitor<? super EventMessage<?>> messageMonitor)
Initializes an event processor with given
name . |
SubscribingEventProcessor(String name,
EventHandlerInvoker eventHandlerInvoker,
RollbackConfiguration rollbackConfiguration,
SubscribableMessageSource<? extends EventMessage<?>> messageSource,
EventProcessingStrategy processingStrategy,
ErrorHandler errorHandler,
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. |
Modifier and Type | Class and Description |
---|---|
class |
RollbackConfigurationType
Enum containing common rollback configurations for the Unit of Work.
|
Modifier and Type | Method and Description |
---|---|
default void |
UnitOfWork.execute(Runnable task,
RollbackConfiguration rollbackConfiguration)
Execute the given
task in the context of this Unit of Work. |
<R> R |
UnitOfWork.executeWithResult(Callable<R> task,
RollbackConfiguration rollbackConfiguration)
Execute the given
task in the context of this Unit of Work. |
<R> R |
DefaultUnitOfWork.executeWithResult(Callable<R> task,
RollbackConfiguration rollbackConfiguration) |
<R> R |
BatchingUnitOfWork.executeWithResult(Callable<R> task,
RollbackConfiguration rollbackConfiguration)
Execute the given
task in the context of this Unit of Work. |
Copyright © 2010–2017. All rights reserved.