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

RetryableAggregateProcessor

class RetryableAggregateProcessor<C : Any, S : Any>(val aggregateId: AggregateId, aggregateMetadata: AggregateMetadata<C, S>, aggregateFactory: StateAggregateFactory, stateAggregateRepository: StateAggregateRepository, commandAggregateFactory: CommandAggregateFactory) : AggregateProcessor<C> , NamedTypedAggregate<C>

Constructors

Link copied to clipboard
constructor(aggregateId: AggregateId, aggregateMetadata: AggregateMetadata<C, S>, aggregateFactory: StateAggregateFactory, stateAggregateRepository: StateAggregateRepository, commandAggregateFactory: CommandAggregateFactory)

Properties

Link copied to clipboard
open override val aggregateId: AggregateId
Link copied to clipboard
open override val processorName: String

Functions

Link copied to clipboard
open override fun process(exchange: ServerCommandExchange<*>): Mono<DomainEventStream>

Processes a command exchange for this aggregate instance.

Generated by Dokka
© 2026 Copyright