Package | Description |
---|---|
org.axonframework.eventsourcing |
Classes related to event sourcing.
|
org.axonframework.modelling.command | |
org.axonframework.modelling.command.inspection | |
org.axonframework.test.aggregate |
Modifier and Type | Class and Description |
---|---|
class |
EventSourcedAggregate<T>
Implementation of an
Aggregate that is sourced from events that have
been published by the aggregate. |
Modifier and Type | Method and Description |
---|---|
protected void |
EventSourcingRepository.validateOnLoad(Aggregate<T> aggregate,
Long expectedVersion) |
protected void |
CachingEventSourcingRepository.validateOnLoad(Aggregate<T> aggregate,
Long expectedVersion) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractRepository<T,A extends Aggregate<T>>
Abstract implementation of the
Repository that takes care of the dispatching of events when an aggregate is
persisted. |
class |
LockAwareAggregate<AR,A extends Aggregate<AR>>
Aggregate implementation that provides access to the lock held by the aggregate while a command is handled.
|
class |
LockingRepository<T,A extends Aggregate<T>>
Implementation of the Repository interface that takes provides a locking mechanism to prevent concurrent
modifications of persisted aggregates.
|
Modifier and Type | Class and Description |
---|---|
class |
LockAwareAggregate<AR,A extends Aggregate<AR>>
Aggregate implementation that provides access to the lock held by the aggregate while a command is handled.
|
Modifier and Type | Method and Description |
---|---|
static <T> Aggregate<T> |
AggregateLifecycle.createNew(Class<T> aggregateType,
Callable<T> factoryMethod)
Creates a new aggregate instance.
|
protected abstract <T> Aggregate<T> |
AggregateLifecycle.doCreateNew(Class<T> aggregateType,
Callable<T> factoryMethod)
Creates a new aggregate instance.
|
Aggregate<T> |
Repository.load(String aggregateIdentifier)
Load the aggregate with the given unique identifier.
|
Aggregate<T> |
Repository.load(String aggregateIdentifier,
Long expectedVersion)
Load the aggregate with the given unique identifier.
|
Aggregate<T> |
Repository.newInstance(Callable<T> factoryMethod)
Creates a new managed instance for the aggregate, using the given
factoryMethod
to instantiate the aggregate's root. |
Modifier and Type | Method and Description |
---|---|
protected Object |
AggregateAnnotationCommandHandler.resolveReturnValue(CommandMessage<?> command,
Aggregate<T> createdAggregate)
Resolves the value to return when the given
command has created the given aggregate . |
protected void |
AbstractRepository.validateOnLoad(Aggregate<T> aggregate,
Long expectedVersion)
Checks the aggregate for concurrent changes.
|
Modifier and Type | Class and Description |
---|---|
class |
AnnotatedAggregate<T>
Implementation of the
Aggregate interface that allows for an aggregate root to be a POJO with annotations on
its Command and Event Handler methods. |
Modifier and Type | Method and Description |
---|---|
protected <R> Aggregate<R> |
AnnotatedAggregate.doCreateNew(Class<R> aggregateType,
Callable<R> factoryMethod) |
Modifier and Type | Method and Description |
---|---|
protected <T> Aggregate<T> |
StubAggregateLifecycle.doCreateNew(Class<T> aggregateType,
Callable<T> factoryMethod) |
Constructor and Description |
---|
ResultValidatorImpl(List<EventMessage<?>> publishedEvents,
FieldFilter fieldFilter,
Supplier<Aggregate<T>> aggregateState,
StubDeadlineManager stubDeadlineManager)
Initialize the ResultValidatorImpl with the given
storedEvents and publishedEvents . |
Copyright © 2010–2019. All rights reserved.