activemq - ActiveMQ が遅い消費者を検出する方法

Question

1. コンシューマが遅いコンシューマであると ActiveMQ が使用する正確なロジックは何ですか?
2. 複数の消費者の場合、同じトピックに接続されている他の消費者も考慮に入れるのが遅いですか?

同じへのコードポインタも提供できれば素晴らしいでしょう

Answer 1

1. 100 行目とTopicSubscription.javaの add メソッドを見てください。

2. 遅いコンシューマとは、パブリッシュされたメッセージの受信が遅れている 1 つの遅いコンシューマです。遅いコンシューマにとって、他のコンシューマがどれだけ「速い」かは問題ではありません。それは、生成されたメッセージと消費されたメッセージの違いです。詳細についてはコードを読むか、質問をより具体的なものに言い換えてください。