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
processingStage
The command stage this filter notifies about.
commandWaitNotifier
The notifier used to send wait signals.
Type Parameters
T
The type of message exchange being filtered.
M
The type of message in the exchange.