WaitStrategyMessagePropagator

Propagator that handles wait strategy propagation from upstream messages.

This propagator extracts wait strategy information from upstream headers and delegates the actual propagation to the wait strategy implementation.

Constructors

constructor()

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

Propagates wait strategy information from the upstream message.