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

SimpleWaitingForChain

class SimpleWaitingForChain(val waitCommandId: String, val materialized: SimpleWaitingChain) : WaitingFor

A waiting strategy that implements a simple chain of command processing stages. This strategy waits for saga handling completion with specific function criteria, then waits for additional commands generated by the saga to complete their processing. It's designed for scenarios where sagas generate follow-up commands that need to be waited on.

Parameters

waitCommandId

The unique identifier for this wait strategy.

materialized

The materialized waiting chain configuration.

Constructors

SimpleWaitingForChain

constructor(waitCommandId: String, materialized: SimpleWaitingChain)

Types

Companion

object Companion

Properties

cancelled

open override val cancelled: Boolean

completed

open override val completed: Boolean

materialized

open override val materialized: SimpleWaitingChain

supportVoidCommand

open override val supportVoidCommand: Boolean = false

Whether this strategy supports void commands.

terminated

open override val terminated: Boolean

waitCommandId

open override val waitCommandId: String

Functions

complete

open override fun complete()

Marks the wait strategy as completed.

error

open override fun error(throwable: Throwable)

Signals an error occurred during command processing.

isPreviousSignal

open override fun isPreviousSignal(signal: WaitSignal): Boolean

Determines if the given wait signal represents a prerequisite stage. Prerequisite signals are those that must complete before this wait strategy can consider its waiting condition satisfied.

open override fun next(signal: WaitSignal)

Receives the next processing result signal from downstream processors.

onFinally

open override fun onFinally(doFinally: Consumer<SignalType>)

Registers a callback to be executed when the strategy completes.

propagate

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

执行传播操作

waiting

open override fun waiting(): Flux<WaitSignal>

Returns a flux of wait signals as processing progresses.

waitingLast

open override fun waitingLast(): Mono<WaitSignal>

Returns a mono that completes with the final wait signal.