6.0.6

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

SimpleWaitingChain

class SimpleWaitingChain(val tail: WaitingChainTail, val function: NamedFunctionInfoData) : WaitStrategy.FunctionMaterialized

Constructors

SimpleWaitingChain

constructor(tail: WaitingChainTail, function: NamedFunctionInfoData)

Types

object Companion

Properties

open override val function: NamedFunctionInfoData

open override val stage: CommandStage

val tail: WaitingChainTail

Functions

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

执行传播操作

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

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

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 override fun shouldPropagate(upstream: Message<*, *>): Boolean

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