message - akka camel 消费者在处理消息之前还是在处理消息之后使消息出列？

Question

class MyConsumer1 extends Consumer {
  def endpointUri = "some protocol string"

  def receive = {
    case msg: CamelMessage ⇒ // processing msg
  }
}

MyConsumer1 是骆驼消费者的一般形式。

问题：receive() 中的 msg 是在调用之前还是在 receive() 之后先出队？端点协议和 autoAck 如何影响出队行为？

Answer 1

我不确定你在这里的意思是什么。您在 Consumer Actor 内部处理的消息不再在 Actors 邮箱中，因为它正在被处理，但这并不意味着 Endpoint 没有等待 Actor 确认它正在处理的消息。从端点正在使用的某些队列中删除。

我认为您的其他问题中已经回答了 autoAck 问题