wow-core/me.ahoo.wow.command.wait/AbstractNotifierFilter

AbstractNotifierFilter

abstract class AbstractNotifierFilter<T : MessageExchange<*, M>, M : Message<*, *>, CommandId, NamedBoundedContext, AggregateIdCapable>(processingStage: CommandStage, commandWaitNotifier: CommandWaitNotifier) : ExchangeFilter<T>

Inheritors

Constructors

Link copied to clipboard
constructor(processingStage: CommandStage, commandWaitNotifier: CommandWaitNotifier)

Functions

Link copied to clipboard
open override fun filter(exchange: T, next: FilterChain<T>): Mono<Void>

实现过滤逻辑的方法 该方法接收一个上下文对象和一个过滤链对象，执行过滤逻辑后，必须调用过滤链的next方法继续执行链上的下一个过滤器