Functions

Link copied to clipboard
open override fun propagate(header: Header, upstream: Message<*, *>)

将上游消息的上下文信息传播到目标头部

abstract fun propagate(commandWaitEndpoint: String, header: Header)

执行传播操作

Link copied to clipboard
abstract fun shouldNotify(processingStage: CommandStage): Boolean

Early assertions, used to determine whether notification is required.

abstract fun shouldNotify(signal: WaitSignal): Boolean

Determine whether the wait signal should trigger a notification.

Link copied to clipboard
open fun shouldPropagate(upstream: Message<*, *>): Boolean

判断是否应该传播指定的消息