java - ActiveMQ - 非アクティブなトピックを検出する方法

Question

ActiveMQ で単純なプロデューサーとコンシューマーを使用して非永続トピックを使用しています。プロデューサーは、メッセージを送信せずにアイドル状態になることがあります。

コンシューマー側でこれを検出し (トピックにメッセージがない)、ユーザーに通知したいと考えています。

どうすればいいですか？これに関する情報が見つかりません。

ありがとうアミット

Answer 1

コンシューマはトピックにサブスクライブします。コンシューマーがメッセージを受信して​​いない場合、それはプロデューサーがアイドル状態であることを意味します。キューとは異なり、トピック内のメッセージは本質的に一時的です (永続的なサブスクリプションの詳細は無視されます)。

トピックからメッセージを受信するたびに、コンシューマーにタイムスタンプを更新してもらいます。また、タイムスタンプを定期的に監視して、タイムスタンプが X ミリ秒より古いかどうかをユーザーに通知する別のスレッドを用意します。