6.0.6

wow-core/me.ahoo.wow.command.wait.chain/WaitingChainTail

WaitingChainTail

class WaitingChainTail(val stage: CommandStage, val function: NamedFunctionInfoData) : WaitStrategy.FunctionMaterialized

Constructors

WaitingChainTail

constructor(stage: CommandStage, function: NamedFunctionInfoData)

Types

object Companion

Properties

open override val function: NamedFunctionInfoData

open override val stage: CommandStage

Functions

open override fun propagate(header: Header, upstream: Message<*, *>)

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

open override fun propagate(commandWaitEndpoint: String, header: Header)

执行传播操作

open override fun shouldNotify(processingStage: CommandStage): Boolean

Early assertions, used to determine whether notification is required.

open override fun shouldNotify(signal: WaitSignal): Boolean

Determine whether the wait signal should trigger a notification.

shouldPropagate

open fun shouldPropagate(upstream: Message<*, *>): Boolean

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