| Package | Description |
|---|---|
| org.axonframework.commandhandling.disruptor | |
| org.axonframework.commandhandling.model | |
| org.axonframework.commandhandling.model.inspection | |
| org.axonframework.eventsourcing |
Classes related to event sourcing.
|
| org.axonframework.spring.eventsourcing | |
| org.axonframework.test.aggregate |
| Modifier and Type | Method and Description |
|---|---|
<T> Repository<T> |
DisruptorCommandBus.createRepository(EventStore eventStore,
AggregateFactory<T> aggregateFactory,
ParameterResolverFactory parameterResolverFactory,
HandlerDefinition handlerDefinition,
RepositoryProvider repositoryProvider)
Creates a repository instance for an Event Sourced aggregate that is created by the given
aggregateFactory and sourced from given eventStore. |
<T> Repository<T> |
DisruptorCommandBus.createRepository(EventStore eventStore,
AggregateFactory<T> aggregateFactory,
RepositoryProvider repositoryProvider)
Creates a repository instance for an Event Sourced aggregate that is created by the given
eventStore and aggregateFactory. |
<T> Repository<T> |
DisruptorCommandBus.createRepository(EventStore eventStore,
AggregateFactory<T> aggregateFactory,
SnapshotTriggerDefinition snapshotTriggerDefinition,
ParameterResolverFactory parameterResolverFactory,
HandlerDefinition handlerDefinition,
RepositoryProvider repositoryProvider)
Creates a repository instance for an Event Sourced aggregate, sourced from given
eventStore, that is
created by the given aggregateFactory. |
<T> Repository<T> |
DisruptorCommandBus.createRepository(EventStore eventStore,
AggregateFactory<T> aggregateFactory,
SnapshotTriggerDefinition snapshotTriggerDefinition,
RepositoryProvider repositoryProvider)
Creates a repository instance for an Event Sourced aggregate, source from given
eventStore, that is
created by the given aggregateFactory. |
<T> Repository<T> |
CommandHandlerInvoker.createRepository(EventStore eventStore,
RepositoryProvider repositoryProvider,
AggregateFactory<T> aggregateFactory,
SnapshotTriggerDefinition snapshotTriggerDefinition,
ParameterResolverFactory parameterResolverFactory,
HandlerDefinition handlerDefinition)
Create a repository instance for an aggregate created by the given
aggregateFactory. |
| Constructor and Description |
|---|
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. |
GenericJpaRepository(EntityManagerProvider entityManagerProvider,
Class<T> aggregateType,
EventBus eventBus,
RepositoryProvider repositoryProvider)
Initialize a repository for storing aggregates of the given
aggregateType. |
GenericJpaRepository(EntityManagerProvider entityManagerProvider,
Class<T> aggregateType,
EventBus eventBus,
RepositoryProvider repositoryProvider,
Function<String,?> identifierConverter)
Initialize a repository for storing aggregates of the given
aggregateType. |
GenericJpaRepository(EntityManagerProvider entityManagerProvider,
Class<T> aggregateType,
EventBus eventBus,
RepositoryProvider repositoryProvider,
LockFactory lockFactory)
Initialize a repository for storing aggregates of the given
aggregateType with an additional LockFactory. |
GenericJpaRepository(EntityManagerProvider entityManagerProvider,
Class<T> aggregateType,
EventBus eventBus,
RepositoryProvider repositoryProvider,
LockFactory lockFactory,
Function<String,?> identifierConverter)
Initialize a repository for storing aggregates of the given
aggregateType with an additional LockFactory and allowing for a custom identifierConverter to convert a String based identifier to an
Identifier Object. |
GenericJpaRepository(EntityManagerProvider entityManagerProvider,
Class<T> aggregateType,
EventBus eventBus,
RepositoryProvider repositoryProvider,
LockFactory lockFactory,
ParameterResolverFactory parameterResolverFactory,
HandlerDefinition handlerDefinition)
Initialize a repository for storing aggregates of the given
aggregateType with an additional LockFactory. |
GenericJpaRepository(EntityManagerProvider entityManagerProvider,
Class<T> aggregateType,
EventBus eventBus,
RepositoryProvider repositoryProvider,
LockFactory lockFactory,
ParameterResolverFactory parameterResolverFactory,
HandlerDefinition handlerDefinition,
Function<String,?> identifierConverter)
Initialize a repository for storing aggregates of the given
aggregateType with an additional LockFactory and allowing for a custom identifierConverter to convert a String based identifier to an
Identifier Object. |
GenericJpaRepository(EntityManagerProvider entityManagerProvider,
Class<T> aggregateType,
EventBus eventBus,
RepositoryProvider repositoryProvider,
ParameterResolverFactory parameterResolverFactory,
HandlerDefinition handlerDefinition)
Initialize a repository for storing aggregates of the given
aggregateType. |
| Modifier and Type | Method and Description |
|---|---|
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,
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,
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,
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(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.reconstruct(T aggregateRoot,
AggregateModel<T> model,
long seqNo,
boolean isDeleted,
EventBus eventBus,
RepositoryProvider repositoryProvider,
SnapshotTrigger snapshotTrigger)
Reconstructs an EventSourcedAggregate instance with given
aggregateRoot. |
EventSourcedAggregate<T> |
AggregateCacheEntry.recreateAggregate(AggregateModel<T> model,
EventStore eventStore,
RepositoryProvider repositoryProvider,
SnapshotTriggerDefinition snapshotTriggerDefinition) |
| Constructor and Description |
|---|
AggregateSnapshotter(EventStore eventStore,
List<AggregateFactory<?>> aggregateFactories,
ParameterResolverFactory parameterResolverFactory,
HandlerDefinition handlerDefinition,
Executor executor,
TransactionManager transactionManager,
RepositoryProvider repositoryProvider)
Initializes a snapshotter that stores snapshots using the given
executor. |
AggregateSnapshotter(EventStore eventStore,
List<AggregateFactory<?>> aggregateFactories,
ParameterResolverFactory parameterResolverFactory,
HandlerDefinition handlerDefinition,
RepositoryProvider repositoryProvider)
Initializes a snapshotter using the given
parameterResolverFactory. |
AggregateSnapshotter(EventStore eventStore,
List<AggregateFactory<?>> aggregateFactories,
RepositoryProvider repositoryProvider)
Initializes a snapshotter using the ParameterResolverFactory instances available on the classpath.
|
AggregateSnapshotter(EventStore eventStore,
RepositoryProvider repositoryProvider,
AggregateFactory<?>... aggregateFactories)
Initializes a snapshotter using the ParameterResolverFactory instances available on the classpath.
|
CachingEventSourcingRepository(AggregateFactory<T> aggregateFactory,
EventStore eventStore,
Cache cache,
RepositoryProvider repositoryProvider)
Initializes a repository with a the given
aggregateFactory and a pessimistic locking strategy. |
CachingEventSourcingRepository(AggregateFactory<T> aggregateFactory,
EventStore eventStore,
Cache cache,
SnapshotTriggerDefinition snapshotTriggerDefinition,
RepositoryProvider repositoryProvider)
Initializes a repository with a the given
aggregateFactory and a pessimistic locking strategy. |
CachingEventSourcingRepository(AggregateFactory<T> aggregateFactory,
EventStore eventStore,
LockFactory lockFactory,
Cache cache,
ParameterResolverFactory parameterResolverFactory,
HandlerDefinition handlerDefinition,
SnapshotTriggerDefinition snapshotTriggerDefinition,
RepositoryProvider repositoryProvider)
Initializes a repository with a the given
aggregateFactory and a pessimistic locking strategy. |
CachingEventSourcingRepository(AggregateFactory<T> aggregateFactory,
EventStore eventStore,
LockFactory lockFactory,
Cache cache,
SnapshotTriggerDefinition snapshotTriggerDefinition,
RepositoryProvider repositoryProvider)
Initializes a repository with a the given
aggregateFactory and a pessimistic locking strategy. |
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(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. |
EventSourcingRepository(AggregateFactory<T> aggregateFactory,
EventStore eventStore,
LockFactory lockFactory,
ParameterResolverFactory parameterResolverFactory,
HandlerDefinition handlerDefinition,
SnapshotTriggerDefinition snapshotTriggerDefinition,
RepositoryProvider repositoryProvider)
Initialize a repository with the given locking strategy and parameter resolver factory.
|
EventSourcingRepository(AggregateFactory<T> aggregateFactory,
EventStore eventStore,
LockFactory lockFactory,
SnapshotTriggerDefinition snapshotTriggerDefinition,
RepositoryProvider repositoryProvider)
Initialize a repository with the given locking strategy.
|
EventSourcingRepository(AggregateFactory<T> aggregateFactory,
EventStore eventStore,
ParameterResolverFactory parameterResolverFactory,
HandlerDefinition handlerDefinition,
SnapshotTriggerDefinition snapshotTriggerDefinition,
RepositoryProvider repositoryProvider)
Initializes a repository with the default locking strategy, using the given
aggregateFactory to
create new aggregate instances. |
EventSourcingRepository(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(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 |
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,
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 |
EventSourcingRepository(Class<T> aggregateType,
EventStore eventStore,
RepositoryProvider repositoryProvider)
Initializes a repository with the default locking strategy, using a GenericAggregateFactory to create new
aggregate instances of given
aggregateType. |
EventSourcingRepository(Class<T> aggregateType,
EventStore eventStore,
SnapshotTriggerDefinition snapshotTriggerDefinition,
RepositoryProvider repositoryProvider)
Initializes a repository with the default locking strategy, using a GenericAggregateFactory to create new
aggregate instances of given
aggregateType. |
| Modifier and Type | Method and Description |
|---|---|
void |
SpringAggregateSnapshotterFactoryBean.setRepositoryProvider(RepositoryProvider repositoryProvider)
Sets repository provider in order to have possibility to spawn new aggregates from THE aggregate.
|
| Constructor and Description |
|---|
SpringAggregateSnapshotter(EventStore eventStore,
ParameterResolverFactory parameterResolverFactory,
HandlerDefinition handlerDefinition,
Executor executor,
TransactionManager txManager,
RepositoryProvider repositoryProvider)
Initializes a snapshotter using the ParameterResolverFactory instances available on the classpath.
|
| Modifier and Type | Method and Description |
|---|---|
FixtureConfiguration<T> |
FixtureConfiguration.registerRepositoryProvider(RepositoryProvider repositoryProvider)
Registers repository provider with the fixture.
|
FixtureConfiguration<T> |
AggregateTestFixture.registerRepositoryProvider(RepositoryProvider repositoryProvider) |
Copyright © 2010–2018. All rights reserved.