ProcessedNotifierFilter
class ProcessedNotifierFilter(commandWaitNotifier: CommandWaitNotifier) : AbstractNotifierFilter<ServerCommandExchange<*>, CommandMessage<*>>
Filter that notifies wait strategies when command processing is complete. Intercepts the command dispatcher pipeline to send PROCESSED stage notifications.
Parameters
commandWaitNotifier
The notifier for sending wait signals.
Functions
Link copied to clipboard
open override fun filter(exchange: ServerCommandExchange<*>, next: FilterChain<ServerCommandExchange<*>>): Mono<Void>
Processes the message exchange and optionally calls the next filter in the chain.