RetryableAggregateProcessorFactory
constructor(stateAggregateFactory: StateAggregateFactory, stateAggregateRepository: StateAggregateRepository, commandAggregateFactory: CommandAggregateFactory, maxRetries: Long = RetryableAggregateProcessor.DEFAULT_MAX_RETRIES)
Parameters
stateAggregateFactory
Factory for creating state aggregates.
stateAggregateRepository
Repository for accessing state aggregates.
commandAggregateFactory
Factory for creating command aggregates.
maxRetries
How many times a recoverable failure is retried, with backoff. 0 runs each command once, as the test DSL does.