RetryableFilter

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

Filter that retries message processing for recoverable errors.

This filter is ordered to run before other processing filters and will retry failed operations according to the specified retry specification.

retrySpec

The retry specification to use (default: DEFAULT_RETRY_SPEC)

Constructors

constructor(retrySpec: Retry = DEFAULT_RETRY_SPEC)

open override fun filter(exchange: T, next: FilterChain<T>): Mono<Void>

Applies retry logic to the filter chain execution.