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

SimpleWaitingChain

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

A simple waiting chain that waits for saga handling completion followed by a tail stage. This strategy combines waiting for saga processing with an additional stage/function criteria. The chain waits for SAGA_HANDLED stage with specific function matching, then waits for the tail stage/function combination.

Parameters

tail

The tail stage and function to wait for after saga handling.

function

The function criteria for saga handling stage.

Constructors

SimpleWaitingChain

constructor(tail: WaitingChainTail, function: NamedFunctionInfoData)

Types

Companion

object Companion

Properties

function

open override val function: NamedFunctionInfoData

stage

open override val stage: CommandStage

tail

val tail: WaitingChainTail

Functions

propagate

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

Executes propagation operation.

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

Propagates context information from an upstream message to the target header.

shouldNotify

open override fun shouldNotify(processingStage: CommandStage): Boolean

Evaluates whether notification is required for the given processing stage. This allows wait strategies to filter notifications based on their waiting criteria.

open override fun shouldNotify(signal: WaitSignal): Boolean

Evaluates whether the wait signal should trigger a notification. Allows for complex filtering logic based on signal properties like stage, function info, error status, etc.

shouldPropagate

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

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