Package | Description |
---|---|
org.axonframework.eventsourcing |
Classes related to event sourcing.
|
Modifier and Type | Method and Description |
---|---|
protected EventSourcedAggregate<T> |
EventSourcingRepository.doCreateNewForLock(Callable<T> factoryMethod) |
protected EventSourcedAggregate<T> |
EventSourcingRepository.doLoadWithLock(String aggregateIdentifier,
Long expectedVersion)
Perform the actual loading of an aggregate.
|
protected EventSourcedAggregate<T> |
CachingEventSourcingRepository.doLoadWithLock(String aggregateIdentifier,
Long expectedVersion)
Perform the actual loading of an aggregate.
|
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) |
Modifier and Type | Method and Description |
---|---|
protected void |
EventSourcingRepository.doDeleteWithLock(EventSourcedAggregate<T> aggregate) |
protected void |
CachingEventSourcingRepository.doDeleteWithLock(EventSourcedAggregate<T> aggregate) |
protected void |
EventSourcingRepository.doSaveWithLock(EventSourcedAggregate<T> aggregate) |
protected void |
CachingEventSourcingRepository.doSaveWithLock(EventSourcedAggregate<T> aggregate) |
Modifier and Type | Method and Description |
---|---|
protected void |
EventSourcingRepository.reportIllegalState(LockAwareAggregate<T,EventSourcedAggregate<T>> aggregate) |
Constructor and Description |
---|
AggregateCacheEntry(EventSourcedAggregate<T> aggregate) |
Copyright © 2010–2024. All rights reserved.