| 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. |
GenericJpaRepository(EntityManagerProvider entityManagerProvider,
AggregateModel<T> aggregateModel,
EventBus eventBus,
RepositoryProvider repositoryProvider)
Initialize a repository for storing aggregates whose structure is defined by given
aggregateModel. |
GenericJpaRepository(EntityManagerProvider entityManagerProvider,
AggregateModel<T> aggregateModel,
EventBus eventBus,
RepositoryProvider repositoryProvider,
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,
RepositoryProvider repositoryProvider,
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. |
static <T> AggregateModel<T> |
AnnotatedAggregateMetaModelFactory.inspectAggregate(Class<T> aggregateType,
ParameterResolverFactory parameterResolverFactory,
HandlerDefinition handlerDefinition)
Shorthand to create a factory instance and inspect the model for the given
aggregateType, using given
parameterResolverFactory to resolve parameter values for annotated handlers and handlerDefinition
to create concrete 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(Callable<T> aggregateFactory,
AggregateModel<T> aggregateModel,
EventBus eventBus,
boolean generateSequences)
Initialize an aggregate created by the given
aggregateFactory which is described in the given
aggregateModel. |
static <T> AnnotatedAggregate<T> |
AnnotatedAggregate.initialize(Callable<T> aggregateFactory,
AggregateModel<T> aggregateModel,
EventBus eventBus,
RepositoryProvider repositoryProvider)
Initialize an aggregate created by the given
aggregateFactory which is described in the given
aggregateModel. |
static <T> AnnotatedAggregate<T> |
AnnotatedAggregate.initialize(Callable<T> aggregateFactory,
AggregateModel<T> aggregateModel,
EventBus eventBus,
RepositoryProvider repositoryProvider,
boolean generateSequences)
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. |
static <T> AnnotatedAggregate<T> |
AnnotatedAggregate.initialize(T aggregateRoot,
AggregateModel<T> aggregateModel,
EventBus eventBus,
RepositoryProvider repositoryProvider)
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(AggregateModel<T> inspector,
EventBus eventBus,
RepositoryProvider repositoryProvider)
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. |
AnnotatedAggregate(T aggregateRoot,
AggregateModel<T> model,
EventBus eventBus,
RepositoryProvider repositoryProvider)
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,
RepositoryProvider repositoryProvider,
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(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,
RepositoryProvider repositoryProvider,
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.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,
RepositoryProvider repositoryProvider,
SnapshotTrigger snapshotTrigger)
Reconstructs an EventSourcedAggregate instance with given
aggregateRoot. |
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,
RepositoryProvider repositoryProvider,
SnapshotTriggerDefinition snapshotTriggerDefinition) |
EventSourcedAggregate<T> |
AggregateCacheEntry.recreateAggregate(AggregateModel<T> model,
EventStore eventStore,
SnapshotTriggerDefinition snapshotTriggerDefinition) |
| Constructor and Description |
|---|
EventSourcedAggregate(AggregateModel<T> model,
EventBus eventBus,
RepositoryProvider repositoryProvider,
SnapshotTrigger snapshotTrigger)
Creates a new EventSourcedAggregate instance based on the given
model, which publishes events to the
given eventBus. |
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,
RepositoryProvider repositoryProvider,
SnapshotTrigger snapshotTrigger)
Initializes an Aggregate instance for the given
aggregateRoot, 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,
RepositoryProvider repositoryProvider)
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 |
EventSourcingRepository(AggregateModel<T> aggregateModel,
AggregateFactory<T> aggregateFactory,
EventStore eventStore,
SnapshotTriggerDefinition snapshotTriggerDefinition,
RepositoryProvider repositoryProvider)
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–2018. All rights reserved.