FailureRecordingHandler

abstract class FailureRecordingHandler<E : EventExchange<*, *>>(chain: FilterChain<E>, errorHandler: ErrorHandler<E>, failureRecorder: FailureRecorder = FailureRecorder.NONE, ackOnUnrecordedFailure: Boolean = true, metrics: WowMetrics = WowMetrics.NONE) : Handler<E>

The event handler of one function: runs chain, then settles the ProcessingOutcome with failureRecorder and hands a failure to errorHandler.

A failure whose in-process retries were exhausted (RetryableFilter) is recorded and handled as its cause, the error the function last failed with, as the wait notifier reports it.

Each outcome is counted in metrics (wow.processing.outcomes, tag outcome) with metricDescriptor.

With FailureRecorder.NONE and ackOnUnrecordedFailure on (the defaults), a failure is logged by the default error handler and acknowledged, as before 9.3.0.

Inheritors

Constructors

Link copied to clipboard
constructor(chain: FilterChain<E>, errorHandler: ErrorHandler<E>, failureRecorder: FailureRecorder = FailureRecorder.NONE, ackOnUnrecordedFailure: Boolean = true, metrics: WowMetrics = WowMetrics.NONE)

Types

Link copied to clipboard
object Companion

Functions

Link copied to clipboard
open override fun handle(context: E): Mono<Void>

Method to execute the handling logic.