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

WaitPlanMessagePropagator

class WaitPlanMessagePropagator : MessagePropagator

Propagates command wait plan headers from upstream messages.

Constructors

constructor()

Functions

propagate

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

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

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.