autoAckConsume

@ExperimentalCoroutinesApi
fun Connection.autoAckConsume(queue: String, prefetch: Int = 100): Flow<ReceivingMessage.AutoAck>