在处理消息或处理完消息之前做了akka骆驼消费者出队消息吗？

Question

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

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

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

问题： msg in receive（）在invokeing之前或receive（）之后先排队？ 端点协议和autoAck如何影响出队行为？

Answer 1

我不确定你在这里指的是什么样的出列队列。您在消费者角色中处理的消息不再处于Actors邮箱中，因为它正在处理中，但这并不意味着该端点不会等待该角色确认它在处理之前处理的消息从端点正在处理的某个队列中删除。

我认为autoAck问题已在your other question