io.eventuate

Class AggregateRepository<T extends CommandProcessingAggregate<T,CT>,CT extends Command>

java.lang.Object

io.eventuate.AggregateRepository<T,CT>

Type Parameters:

T - the aggregate class, which is a subtype of CommandProcessingAggregate

CT - the aggregate's command class, a subtype of command

For example:

             public class AccountService {
             private final AggregateRepository>Account, AccountCommand> accountRepository;
             public AccountService(AggregateRepository>Account, AccountCommand> accountRepository) {
             this.accountRepository = accountRepository;
             }
             public CompletableFuture>EntityWithIdAndVersion>Account>> openAccount(BigDecimal initialBalance) {
             return accountRepository.save(new CreateAccountCommand(initialBalance));
             }
             }
             

public class AggregateRepository<T extends CommandProcessingAggregate<T,CT>,CT extends Command>
extends java.lang.Object

A convenience class, with a reactive-style API that provides a simplified interface for creating and updating aggregates.

See Also:

CommandProcessingAggregate, Command

Constructor Summary

Constructors

Constructor and Description
AggregateRepository(java.lang.Class<T> clasz, EventuateAggregateStore aggregateStore) Constructs a new AggregateRepository for the specified aggregate class and aggregate store

Method Summary

Modifier and Type	Method and Description
java.util.concurrent.CompletableFuture<EntityWithMetadata<T>>	find(java.lang.String entityId) Find an aggregate
java.util.concurrent.CompletableFuture<EntityWithMetadata<T>>	find(java.lang.String entityId, FindOptions findOptions) Find an aggregate
java.util.concurrent.CompletableFuture<EntityWithMetadata<T>>	find(java.lang.String entityId, java.util.Optional<FindOptions> findOptions) Find an aggregate
java.util.concurrent.CompletableFuture<EntityWithIdAndVersion<T>>	save(CT cmd) Create a new Aggregate by processing a command and persisting the events
java.util.concurrent.CompletableFuture<EntityWithIdAndVersion<T>>	save(CT cmd, java.util.Optional<SaveOptions> saveOptions) Create a new Aggregate by processing a command and persisting the events
java.util.concurrent.CompletableFuture<EntityWithIdAndVersion<T>>	update(java.lang.String entityId, CT cmd) Update the specified aggregate by processing a command and saving events
java.util.concurrent.CompletableFuture<EntityWithIdAndVersion<T>>	update(java.lang.String entityId, CT cmd, java.util.Optional<UpdateOptions> updateOptions) Update the specified aggregate by processing a command and saving events
java.util.concurrent.CompletableFuture<EntityWithIdAndVersion<T>>	updateWithProvidedCommand(java.lang.String entityId, java.util.function.Function<T,java.util.Optional<CT>> commandProvider, java.util.Optional<UpdateOptions> updateOptions) Update the specified aggregate by processing a command and saving events

Methods inherited from class java.lang.Object

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

Constructor Detail

AggregateRepository

public AggregateRepository(java.lang.Class<T> clasz,
                           EventuateAggregateStore aggregateStore)

Constructs a new AggregateRepository for the specified aggregate class and aggregate store

Parameters:

clasz - the class of the aggregate

aggregateStore - the aggregate store

Method Detail

save

public java.util.concurrent.CompletableFuture<EntityWithIdAndVersion<T>> save(CT cmd)

Create a new Aggregate by processing a command and persisting the events

Parameters:

cmd - the command to process

Returns:

the newly persisted aggregate

save

public java.util.concurrent.CompletableFuture<EntityWithIdAndVersion<T>> save(CT cmd,
                                                                              java.util.Optional<SaveOptions> saveOptions)

Create a new Aggregate by processing a command and persisting the events

Parameters:

cmd - the command to process

saveOptions - creation options

Returns:

the newly persisted aggregate

update

public java.util.concurrent.CompletableFuture<EntityWithIdAndVersion<T>> update(java.lang.String entityId,
                                                                                CT cmd)

Update the specified aggregate by processing a command and saving events

Parameters:

entityId - the id of the aggregate to update

cmd - the command to process

Returns:

the updated and persisted aggregate

update

public java.util.concurrent.CompletableFuture<EntityWithIdAndVersion<T>> update(java.lang.String entityId,
                                                                                CT cmd,
                                                                                java.util.Optional<UpdateOptions> updateOptions)

Update the specified aggregate by processing a command and saving events

Parameters:

entityId - the id of the aggregate to update

cmd - the command to process

updateOptions - options for updating

Returns:

the updated and persisted aggregate

updateWithProvidedCommand

public java.util.concurrent.CompletableFuture<EntityWithIdAndVersion<T>> updateWithProvidedCommand(java.lang.String entityId,
                                                                                                   java.util.function.Function<T,java.util.Optional<CT>> commandProvider,
                                                                                                   java.util.Optional<UpdateOptions> updateOptions)

Update the specified aggregate by processing a command and saving events

Parameters:

entityId - the id of the aggregate to update

commandProvider - the provider of the command to process

updateOptions - options for updating

Returns:

the updated and persisted aggregate

find

public java.util.concurrent.CompletableFuture<EntityWithMetadata<T>> find(java.lang.String entityId)

Find an aggregate

Parameters:

entityId - the id of the aggregate to find

Returns:

the aggregate

find

public java.util.concurrent.CompletableFuture<EntityWithMetadata<T>> find(java.lang.String entityId,
                                                                          FindOptions findOptions)

Find an aggregate

Parameters:

entityId - the id of the aggregate to find

findOptions - options for finding

Returns:

the aggregate

find

public java.util.concurrent.CompletableFuture<EntityWithMetadata<T>> find(java.lang.String entityId,
                                                                          java.util.Optional<FindOptions> findOptions)

Find an aggregate

Parameters:

entityId - the id of the aggregate to find

findOptions - options for finding

Returns:

the aggregate