AbstractNotifierFilter
abstract class AbstractNotifierFilter<T : MessageExchange<*, M>, M : Message<*, *>, CommandId, NamedBoundedContext, AggregateIdCapable>(processingStage: CommandStage, commandWaitNotifier: CommandWaitNotifier) : ExchangeFilter<T>
Abstract base class for filters that notify wait strategies about command processing completion. These filters intercept message processing pipelines and send notifications to waiting clients when specific processing stages are reached.
Parameters
T
The type of message exchange being filtered.
M
The type of message in the exchange.
processingStage
The command stage this filter notifies about.
commandWaitNotifier
The notifier used to send wait signals.