propagate

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

Propagates the operator information from the upstream message header.

header

The target header to propagate to

upstream

The upstream message to propagate from