SnapshotNotifierFilter

@Order(value = -2147483648)
class SnapshotNotifierFilter(commandWaitNotifier: CommandWaitNotifier) : AbstractNotifierFilter<StateEventExchange<*>, StateEvent<*>>

Constructors

Link copied to clipboard
constructor(commandWaitNotifier: CommandWaitNotifier)

Functions

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

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