wow-core/me.ahoo.wow.command.wait/WaitStrategy/Materialized

Materialized

interface Materialized : ProcessingStageShouldNotifyPredicate, WaitSignalShouldNotifyPredicate, Materialized, WaitStrategyPropagator, MessagePropagator

Inheritors

FunctionMaterialized

Functions

propagate

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

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

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

Executes propagation operation.

shouldNotify

abstract 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.

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

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