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

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

MyConsumer1 はキャメル コンシューマーの一般的な形式です。

質問: receive() 内の msg は、呼び出し前または receive() 後に最初にキューから取り出されますか? エンドポイント プロトコルと autoAck は、デキュー動作にどのように影響しますか?

4

1 に答える 1

0

ここで何を意味するのかわかりません。コンシューマー アクター内で処理しているメッセージは、処理中のためアクターのメールボックスにはありませんが、処理中のメッセージに対してアクターが確認応答するのをエンドポイントが待機していないという意味ではありません。エンドポイントが使用している一部のキューから削除されました。

autoAck の質問は、他の質問で既に回答されていると思います

于 2013-02-07T16:28:04.220 に答える