FailureRecorder

Records event-processing failures durably, so that they can be compensated (retried) later.

The event handlers of event processors, projections, stateless sagas and snapshots call it once per function, after the function's filter chain (including RetryableFilter) has terminated:

The default, NONE, records nothing: a failure is ProcessingOutcome.FAILURE_UNRECORDED. wow-compensation-core provides the durable recorder.

Types

Link copied to clipboard
object Companion

Functions

Link copied to clipboard
abstract fun recordFailure(exchange: EventExchange<*, *>, error: Throwable): Mono<ProcessingOutcome>

Records that the function of exchange failed with error.

Link copied to clipboard
open fun recordSuccess(exchange: EventExchange<*, *>): Mono<Void>

Called after the function of exchange processed its event.