Package | Description |
---|---|
org.axonframework.commandhandling |
Classes that implement the concept of command handling using explicit command objects.
|
org.axonframework.commandhandling.model | |
org.axonframework.commandhandling.model.inspection | |
org.axonframework.eventsourcing |
Classes related to event sourcing.
|
Constructor and Description |
---|
AggregateAnnotationCommandHandler(Repository<T> repository,
CommandTargetResolver commandTargetResolver,
AggregateModel<T> aggregateModel)
Initializes an AnnotationCommandHandler based on the annotations on given
aggregateType , using the
given repository to add and load aggregate instances and the given
parameterResolverFactory . |
Modifier and Type | Method and Description |
---|---|
protected AggregateModel<T> |
AbstractRepository.aggregateModel()
Returns the aggregate model stored by this repository.
|
Constructor and Description |
---|
AbstractRepository(AggregateModel<T> aggregateModel)
Initializes a repository that stores aggregate of the given
aggregateType . |
GenericJpaRepository(EntityManagerProvider entityManagerProvider,
AggregateModel<T> aggregateModel,
EventBus eventBus)
Initialize a repository for storing aggregates whose structure is defined by given
aggregateModel . |
GenericJpaRepository(EntityManagerProvider entityManagerProvider,
AggregateModel<T> aggregateModel,
EventBus eventBus,
LockFactory lockFactory)
Initialize a repository for storing aggregates described by the given
aggregateModel with an additional
LockFactory . |
GenericJpaRepository(EntityManagerProvider entityManagerProvider,
AggregateModel<T> aggregateModel,
EventBus eventBus,
LockFactory lockFactory,
Function<String,?> identifierConverter)
Initialize a repository for storing aggregates described by the given
AggregateModel , with an additional
LockFactory and allowing for a custom identifierConverter to convert a String based identifier to
an Identifier Object. |
LockingRepository(AggregateModel<T> aggregateModel)
Initialize a repository with a pessimistic locking strategy, using the given
aggregateModel , describing
the structure of the aggregate. |
LockingRepository(AggregateModel<T> aggregateModel,
LockFactory lockFactory)
Initialize the repository with the given
LockFactory and aggregateModel |
Modifier and Type | Class and Description |
---|---|
class |
ModelInspector<T>
Deprecated.
in favor of using one of the
AggregateMetaModelFactory implementations |
Modifier and Type | Method and Description |
---|---|
<T> AggregateModel<T> |
AggregateMetaModelFactory.createModel(Class<? extends T> aggregateType)
Create an Aggregate meta model for the given
aggregateType . |
static <AT> AggregateModel<AT> |
ModelInspector.inspectAggregate(Class<AT> aggregateType)
Deprecated.
Create an inspector for given
aggregateType that uses a ClasspathParameterResolverFactory to
resolve method parameters. |
static <T> AggregateModel<T> |
AnnotatedAggregateMetaModelFactory.inspectAggregate(Class<T> aggregateType)
Shorthand to create a factory instance and inspect the model for the given
aggregateType . |
static <T> AggregateModel<T> |
ModelInspector.inspectAggregate(Class<T> aggregateType,
ParameterResolverFactory parameterResolverFactory)
Deprecated.
Create an inspector for given
aggregateType that uses given parameterResolverFactory to resolve
method parameters. |
static <T> AggregateModel<T> |
AnnotatedAggregateMetaModelFactory.inspectAggregate(Class<T> aggregateType,
ParameterResolverFactory parameterResolverFactory)
Shorthand to create a factory instance and inspect the model for the given
aggregateType , using given
parameterResolverFactory to resolve parameter values for annotated handlers. |
Modifier and Type | Method and Description |
---|---|
static <T> AnnotatedAggregate<T> |
AnnotatedAggregate.initialize(Callable<T> aggregateFactory,
AggregateModel<T> aggregateModel,
EventBus eventBus)
Initialize an aggregate created by the given
aggregateFactory which is described in the given
aggregateModel . |
static <T> AnnotatedAggregate<T> |
AnnotatedAggregate.initialize(T aggregateRoot,
AggregateModel<T> aggregateModel,
EventBus eventBus)
Initialize an aggregate with the given
aggregateRoot which is described in the given
aggregateModel . |
Constructor and Description |
---|
AnnotatedAggregate(AggregateModel<T> inspector,
EventBus eventBus)
Initialize an Aggregate instance for the given
aggregateRoot , described by the given
aggregateModel that will publish events to the given eventBus . |
AnnotatedAggregate(T aggregateRoot,
AggregateModel<T> model,
EventBus eventBus)
Initialize an Aggregate instance for the given
aggregateRoot , described by the given
aggregateModel that will publish events to the given eventBus . |
Modifier and Type | Method and Description |
---|---|
static <T> EventSourcedAggregate<T> |
EventSourcedAggregate.initialize(Callable<T> aggregateFactory,
AggregateModel<T> inspector,
EventBus eventBus,
SnapshotTrigger snapshotTrigger)
Initializes an EventSourcedAggregate instance using the given
aggregateFactory , based on the given inspector , which publishes events to the given eventBus and stores events in the given eventStore . |
static <T> EventSourcedAggregate<T> |
EventSourcedAggregate.initialize(T aggregateRoot,
AggregateModel<T> inspector,
EventBus eventBus,
SnapshotTrigger snapshotTrigger)
Initializes an EventSourcedAggregate instance for the given
aggregateRoot , based on the given inspector , which publishes events to the given eventBus . |
static <T> EventSourcedAggregate<T> |
EventSourcedAggregate.reconstruct(T aggregateRoot,
AggregateModel<T> model,
long seqNo,
boolean isDeleted,
EventBus eventBus,
SnapshotTrigger snapshotTrigger)
Reconstructs an EventSourcedAggregate instance with given
aggregateRoot . |
EventSourcedAggregate<T> |
AggregateCacheEntry.recreateAggregate(AggregateModel<T> model,
EventStore eventStore,
SnapshotTriggerDefinition snapshotTriggerDefinition) |
Constructor and Description |
---|
EventSourcedAggregate(AggregateModel<T> model,
EventBus eventBus,
SnapshotTrigger snapshotTrigger)
Creates a new EventSourcedAggregate instance based on the given
model , which publishes events to the
given eventBus . |
EventSourcedAggregate(T aggregateRoot,
AggregateModel<T> model,
EventBus eventBus,
SnapshotTrigger snapshotTrigger)
Initializes an Aggregate instance for the given
aggregateRoot , based on the given model , which
publishes events to the given eventBus . |
EventSourcingRepository(AggregateModel<T> aggregateModel,
AggregateFactory<T> aggregateFactory,
EventStore eventStore)
Initializes a repository with the default locking strategy, using the given
aggregateFactory to
create new aggregate instances. |
EventSourcingRepository(AggregateModel<T> aggregateModel,
AggregateFactory<T> aggregateFactory,
EventStore eventStore,
SnapshotTriggerDefinition snapshotTriggerDefinition)
Initializes a repository with the default locking strategy, using the given
aggregateFactory to
create new aggregate instances and triggering snapshots using the given snapshotTriggerDefinition |
Copyright © 2010–2017. All rights reserved.