DefaultStatelessSagaHandler
class DefaultStatelessSagaHandler(chain: FilterChain<DomainEventExchange<*>>, errorHandler: ErrorHandler<DomainEventExchange<*>> = LogResumeErrorHandler(), failureRecorder: FailureRecorder = FailureRecorder.NONE, ackOnUnrecordedFailure: Boolean = true, metrics: WowMetrics = WowMetrics.NONE) : FailureRecordingHandler<DomainEventExchange<*>> , StatelessSagaHandler
Default implementation of StatelessSagaHandler that uses a filter chain for processing. This handler applies a series of filters to domain event exchanges and handles errors gracefully.
Parameters
chain
The filter chain to apply to domain event exchanges.
errorHandler
The error handler for processing failures (default: LogResumeErrorHandler).
failureRecorder
Records failures durably (default: none).
ackOnUnrecordedFailure
Whether a failure no recorder recorded is acknowledged (default: true).
metrics
Counts the processing outcomes (default: none).
Constructors
Link copied to clipboard
constructor(chain: FilterChain<DomainEventExchange<*>>, errorHandler: ErrorHandler<DomainEventExchange<*>> = LogResumeErrorHandler(), failureRecorder: FailureRecorder = FailureRecorder.NONE, ackOnUnrecordedFailure: Boolean = true, metrics: WowMetrics = WowMetrics.NONE)