io.eventuate

Interface EventHandlerContext<T extends Event>

Type Parameters:

T - the type of the event

All Superinterfaces:

EventEnvelope<T>

public interface EventHandlerContext<T extends Event>
extends EventEnvelope<T>

Wraps the event that is passed to a command-side event handler

Method Summary

Modifier and Type	Method and Description
<A extends CommandProcessingAggregate<A,CT>,CT extends Command> java.util.concurrent.CompletableFuture<EntityWithIdAndVersion<A>>	save(java.lang.Class<A> entityClass, CT command, java.util.Optional<java.lang.String> entityId) Creates an aggregate in response to an event
<A extends CommandProcessingAggregate<A,CT>,CT extends Command> java.util.concurrent.CompletableFuture<EntityWithIdAndVersion<A>>	update(java.lang.Class<A> entityClass, java.lang.String entityId, CT command) Updates an aggregate in response to an event
<A extends CommandProcessingAggregate<A,CT>,CT extends Command> java.util.concurrent.CompletableFuture<EntityWithIdAndVersion<A>>	updateWithProvidedCommand(java.lang.Class<A> entityClass, java.lang.String entityId, java.util.function.Function<A,java.util.Optional<CT>> commandProvider) Updates an aggregate in response to an event

Methods inherited from interface io.eventuate.EventEnvelope

getEntityId, getEvent, getEventContext, getEventId, getEventMetadata, getEventType, getOffset, getSwimlane

Method Detail

save

<A extends CommandProcessingAggregate<A,CT>,CT extends Command> java.util.concurrent.CompletableFuture<EntityWithIdAndVersion<A>> save(java.lang.Class<A> entityClass,
                                                                                                                                       CT command,
                                                                                                                                       java.util.Optional<java.lang.String> entityId)

Creates an aggregate in response to an event

Type Parameters:

A - the aggregate class

CT - the command class

Parameters:

entityClass - the class of the aggregate to create, must be a subclass of CommandProcessingAggregate

command - the command to process

entityId - the optional id of the aggregate to create

Returns:

the newly created and persisted aggregate

update

<A extends CommandProcessingAggregate<A,CT>,CT extends Command> java.util.concurrent.CompletableFuture<EntityWithIdAndVersion<A>> update(java.lang.Class<A> entityClass,
                                                                                                                                         java.lang.String entityId,
                                                                                                                                         CT command)

Updates an aggregate in response to an event

Type Parameters:

A - the aggregate class

CT - the command class

Parameters:

entityClass - the class of the aggregate to create, must be a subclass of CommandProcessingAggregate

command - the command to process

entityId - the optional id of the aggregate to create

Returns:

the updated and persisted aggregate

updateWithProvidedCommand

<A extends CommandProcessingAggregate<A,CT>,CT extends Command> java.util.concurrent.CompletableFuture<EntityWithIdAndVersion<A>> updateWithProvidedCommand(java.lang.Class<A> entityClass,
                                                                                                                                                            java.lang.String entityId,
                                                                                                                                                            java.util.function.Function<A,java.util.Optional<CT>> commandProvider)

Updates an aggregate in response to an event

Type Parameters:

A - the aggregate class

CT - the command class

Parameters:

entityClass - the class of the aggregate to create, must be a subclass of CommandProcessingAggregate

commandProvider - provides the command to process

entityId - the optional id of the aggregate to create

Returns:

the updated and persisted aggregate