connector-amqp/com.river.connector.amqp/consume

consume

@ExperimentalCoroutinesApi
@ExperimentalRiverApi
fun Connection.consume(queue: String, prefetch: Int = 100): Flow<ReceivingMessage.ManualAck>