propagate

fun propagate(commandWaitEndpoint: String, header: Header)
fun propagate(header: Header, upstream: Message<*, *>)