connector-amqp/com.river.connector.amqp/publishFlow

publishFlow

@ExperimentalRiverApi
fun Connection.publishFlow(exchange: String, routingKey: String, upstream: Flow<Message.Simple>): Flow<Unit>
@ExperimentalRiverApi
fun Channel.publishFlow(exchange: String, routingKey: String, upstream: Flow<Message.Simple>): Flow<Unit>
@ExperimentalRiverApi
fun Channel.publishFlow(upstream: Flow<Message.Default>): Flow<Unit>