wow-core/me.ahoo.wow.messaging.propagation/WaitPlanMessagePropagator/propagate

propagate

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

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

Parameters

header

The target message header to receive propagated context data

upstream

The upstream message providing context information to propagate

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

Propagates context from upstream to the header of a message that producer creates from it, such as a command a saga function sends for an event. A propagator whose keys belong to one downstream function only (the wait chain) uses producer to decide; the default ignores it.