正确Go / RabbitMQ方式从队列中“弹出”一条消息？

我的第一个问题是设计问题。我试图确定是否应该以这样的方式编写我的worker，即它只是从队列中弹出一条消息，处理它，然后关闭它。像Kubernetes这样的东西看起来相当微不足道。但是如果它消失（由于错误或事故），它会重新启动？

我问这个问题的原因是，为了实现前者，它感觉“被黑了”，因为我必须使用常见的AMQP库来编写以下内容streadway/amqp（阅读评论）：

// Pop will extract a message from the AMQP queue
func (v *Queue) Pop() (data []byte, err error) {

msgs, err := v.Channel.Consume(
    v.QueueName, // queue
    v.ConsmerID, // consumer
    true,        // auto-ack
    false,       // exclusive
    false,       // no-local
    false,       // no-wait
    nil,         // args
)
if err != nil {
    return nil, err
}

// We have to use for .. range because Consume returns
// "<-chan Delivery" but if we only want ONE message popped off
// we return on the first one
for data := range msgs {
    return data.Body, nil
}

// We should never get this far...
return nil, errors.New("Something went wrong")

}
此外，<-chan Delivery在这种情况下是什么？它似乎可以插入某种“流”或对象。有没有办法不必为这些数据类型编写for循环？

编辑：我还发现，这个代码似乎会使ENTIRE队列出列，即使它只进行一次for循环迭代（如上面的代码所示）。我不知道为什么会发生这种情况？