ProjectedNotifierFilter
class ProjectedNotifierFilter(commandWaitNotifier: CommandWaitNotifier) : AbstractNotifierFilter<DomainEventExchange<Any>, DomainEvent<*>>
Filter that notifies wait strategies when projections are updated. Intercepts the projection dispatcher pipeline to send PROJECTED 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.