wow-core/me.ahoo.wow.modeling.command/AggregateProcessor

AggregateProcessor

interface AggregateProcessor<C : Any> : AggregateIdCapable, NamedTypedAggregate<C> , MonoMessageProcessor<C, ServerCommandExchange<*>, Mono<DomainEventStream>>

Processor for handling commands on a specific aggregate instance.

This interface defines the contract for processing commands against a particular aggregate, ensuring proper serialization and state management.

Type Parameters

C

The type of the command aggregate root.

Inheritors

CommandAggregate

RetryableAggregateProcessor

Properties

abstract override val aggregateId: AggregateId

Functions

abstract override fun process(exchange: ServerCommandExchange<*>): Mono<DomainEventStream>

Processes a command exchange for this aggregate instance.