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

RetryableFilter

@Order(before = [AggregateProcessorFilter::class, DomainEventFunctionFilter::class, SnapshotFunctionFilter::class])
class RetryableFilter<T : MessageExchange<*, *>>(retrySpec: Retry = DEFAULT_RETRY_SPEC) : ExchangeFilter<T>

Constructors

Link copied to clipboard
constructor(retrySpec: Retry = DEFAULT_RETRY_SPEC)

Functions

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