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.