propagate

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

Executes propagation operation.

Propagates command processing results to the specified wait endpoint.

commandWaitEndpoint

the command wait endpoint address

header

message header containing metadata and context

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

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

header

The target message header to receive propagated context data

upstream

The upstream message providing context information to propagate