SagaHandledNotifierFilter
class SagaHandledNotifierFilter(commandWaitNotifier: CommandWaitNotifier) : AbstractNotifierFilter<DomainEventExchange<Any>, DomainEvent<*>>
Filter that notifies wait strategies when domain events are handled by sagas. Intercepts the stateless saga dispatcher pipeline to send SAGA_HANDLED stage notifications.
Parameters
commandWaitNotifier
The notifier for sending wait signals.
Functions
Link copied to clipboard
open override fun filter(exchange: DomainEventExchange<Any>, next: FilterChain<DomainEventExchange<Any>>): Mono<Void>
Processes the message exchange and optionally calls the next filter in the chain.