EventHandledNotifierFilter

Filter that notifies wait strategies when domain events are handled by event processors. Intercepts the domain event dispatcher pipeline to send EVENT_HANDLED stage notifications.

Parameters

commandWaitNotifier

The notifier for sending wait signals.

Constructors

Link copied to clipboard
constructor(commandWaitNotifier: CommandWaitNotifier)

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.