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

filter

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

Applies retry logic to the filter chain execution.

Return

A Mono that will retry on recoverable failures

Parameters

exchange

The message exchange to process

next

The next filter in the chain