Package-level declarations

Types

Link copied to clipboard

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

Link copied to clipboard
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.

Link copied to clipboard

How the processing of one event by one function ended, and so whether its message is acknowledged.