io.eventuate

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

java.lang.Object

io.eventuate.CommonAggregateRepository<T,CT>

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 CommonAggregateRepository<T,CT>

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

See Also:

CommandProcessingAggregate, Command

Field Summary

Fields inherited from class io.eventuate.CommonAggregateRepository

clasz, interceptor, missingApplyEventMethodStrategy

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 io.eventuate.CommonAggregateRepository

setInterceptor, setMissingApplyEventMethodStrategy, transformUpdateEventsAndOptions

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