SnapshotNotifierFilter
class SnapshotNotifierFilter(commandWaitNotifier: CommandWaitNotifier) : AbstractNotifierFilter<StateEventExchange<*>, StateEvent<*>>
Filter that notifies wait strategies when aggregate snapshots are generated. Intercepts the snapshot dispatcher pipeline to send SNAPSHOT stage notifications.
Parameters
commandWaitNotifier
The notifier for sending wait signals.
Functions
Link copied to clipboard
open override fun filter(exchange: StateEventExchange<*>, next: FilterChain<StateEventExchange<*>>): Mono<Void>
Processes the message exchange and optionally calls the next filter in the chain.