RetryableAggregateProcessorFactory
class RetryableAggregateProcessorFactory(stateAggregateFactory: StateAggregateFactory, stateAggregateRepository: StateAggregateRepository, commandAggregateFactory: CommandAggregateFactory) : AggregateProcessorFactory
Factory that creates retryable aggregate processors.
This implementation provides resilience by creating processors that can handle transient failures and retry operations as needed.
Parameters
stateAggregateFactory
Factory for creating state aggregates.
stateAggregateRepository
Repository for accessing state aggregates.
commandAggregateFactory
Factory for creating command aggregates.
Constructors
Link copied to clipboard
constructor(stateAggregateFactory: StateAggregateFactory, stateAggregateRepository: StateAggregateRepository, commandAggregateFactory: CommandAggregateFactory)
Functions
Link copied to clipboard
open override fun <C : Any, S : Any> create(aggregateId: AggregateId, aggregateMetadata: AggregateMetadata<C, S>): AggregateProcessor<C>
Creates a retryable aggregate processor.