wow-core/me.ahoo.wow.messaging.handler

Package-level declarations

Types

Utilities for acknowledging message exchanges.

A filter for processing message exchanges in a filter chain.

class RetryableFilter<T : MessageExchange<*, *>>(retrySpec: Retry = DEFAULT_RETRY_SPEC) : ExchangeFilter<T>

Filter that retries message processing for recoverable errors.

val DEFAULT_RETRY_SPEC: RetryBackoffSpec

Default retry specification for recoverable errors.

fun retryStrategy(maxAttempts: Long = MAX_RETRIES, minBackoff: Duration = MIN_BACKOFF, logger: KLogger): Retry

Creates a retry strategy with exponential backoff and logging.