Class DefaultAggregateRepository.AnnotatedAggregateRepository<T>

java.lang.Object

io.fluxzero.sdk.persisting.repository.DefaultAggregateRepository.AnnotatedAggregateRepository<T>

Type Parameters:

T - the aggregate root type

Enclosing class:

DefaultAggregateRepository

public class DefaultAggregateRepository.AnnotatedAggregateRepository<T>
extends Object

Aggregate-type-specific delegate used internally by DefaultAggregateRepository.

This class is instantiated per aggregate class and parses metadata from the Aggregate annotation to determine:

• Whether the aggregate is event-sourced or backed by the document store.
• If and how frequently snapshots should be created.
• Whether the aggregate is indexed for search.
• How events should be published and committed.
• Which cache(s) to use.

It provides loading and committing capabilities tailored to the configured storage and publication strategy. It also supports refetching aggregates from the Fluxzero Runtime and maintaining relationships with child entities.

Snapshot and document-based aggregates are supported out of the box. Event replay is triggered as needed.

This class is not intended to be used directly outside the DefaultAggregateRepository.

Constructor Summary

Constructors

Constructor	Description
AnnotatedAggregateRepository(Class<T> type)

Method Summary

Modifier and Type	Method	Description
void	commit(Entity<?> after, List<AppliedEvent> unpublishedEvents, Entity<?> before)
CompletableFuture<Void>	delete(Object id)
protected Entity<T>	eventSourceModel(Entity<T> model)
Entity<T>	fromValue(T value)
Entity<T>	load(Object id)
protected Entity<T>	loadSnapshot(Object id)
protected ImmutableAggregateRoot<T>	restoreSnapshotId(Object id, Entity<T> snapshot)
protected boolean	updatesAggregateState(AppliedEvent event)
protected Entity<T>	withHistoricalSnapshots(ImmutableAggregateRoot<T> snapshot, Object aggregateId)

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

AnnotatedAggregateRepository

public AnnotatedAggregateRepository(Class<T> type)

Method Details

fromValue

public Entity<T> fromValue(T value)

delete

public CompletableFuture<Void> delete(Object id)

load

public Entity<T> load(Object id)

loadSnapshot

protected Entity<T> loadSnapshot(Object id)

restoreSnapshotId

protected ImmutableAggregateRoot<T> restoreSnapshotId(Object id,
 Entity<T> snapshot)

withHistoricalSnapshots

protected Entity<T> withHistoricalSnapshots(ImmutableAggregateRoot<T> snapshot,
 Object aggregateId)

eventSourceModel

protected Entity<T> eventSourceModel(Entity<T> model)

commit

public void commit(Entity<?> after,
 List<AppliedEvent> unpublishedEvents,
 Entity<?> before)

updatesAggregateState

protected boolean updatesAggregateState(AppliedEvent event)