ActiveMQの購読済みおよび未送信のトピックメッセージの数

Question

ActiveMQをメッセージのブローカーとして使用して簡単なチャットアプリケーションをセットアップしました。チャットは、両方の当事者がメッセージを発行し、両方の当事者がメッセージを購読できるトピックです。メッセージには、送信者IDや受信者IDのような、メッセージに関するいくつかのメタデータが含まれています。それはすべて正常に動作します。

チャットメッセージを待っているすべてのユーザー、つまりオフラインになっていて、読まれるのを待っているトピックの公開メッセージがあります。これらのユーザーは、新しいメッセージを読むことについての別のプラットフォームを使用して（モバイルに）通知を受け取る必要があります。

すべてのActiveMQのドキュメントとフォーラムで回答を検索しましたが、何も見つかりませんでした（理解していない可能性があります）。これは、MQが処理するための明白なクエリのようです...

ブローカのI'vが有効になっており、EnqueueCount/DequeueCountが見つかりましたが、送信されたメッセージの合計数すべての加入者）。

Answer 1

どのメッセージが公開され、どのメッセージが消費された（消費されていない）のかを知るためにできることは、advisory messagesを聞くことができます。

「管理アプリ」からActiveMQ.Advisory.MessageDelivered.Topicを購読して、配信されたメッセージを確認してください。

ActiveMQ.Advisory.MessageConsumed.Topicにサブスクライブして、どのメッセージが消費されているか調べてください。

次に、時間枠内で消費されていないメッセージがあり、何らかのアクションを取る必要がある（他の方法でユーザーに通知する）場合は、多少の作業で可能性があります。

この設定を有効にする必要があります。

<destinationPolicy> 
    <policyMap><policyEntries> 
     <policyEntry topic=">" advisoryForConsumed="true" /> 
    </policyEntries></policyMap> 
</destinationPolicy> 

Answer 2

恒久サブスクリプションを調べます。これにより、ブローカはどのユーザがどのメッセージを受信したかを把握し、「一時停止」問題をサポートする各ユーザのサブスクリプションを作成します。

追加クレジット：代わりに仮想トピックを使用してください。それはトピックに公開されています - >キューの意味論から購読します。柔軟性が増し、保守が容易になります。

注：

1. プロデューサー先：：トピック：//My.Topic
2. 購読1つの宛先名：キュー：コンフィグサンプル

   <broker...> 
   .... <!-- be sure to place elements after "<broker>" in alphabetical order --> 
   <destinationInterceptors> 
        <virtualDestinationInterceptor> 
         <virtualDestinations> 
         <virtualTopic name=">" prefix="VirtualTopicConsumers.*." selectorAware="false"/> 
        </virtualDestinations> 
       </virtualDestinationInterceptor> 
   </destinationInterceptors> 
   ... 
   </broker> 
   

   のために編集がその後に自分のプロデューサーを設定//VirtualTopicConsumers.Sub1.My.Topic

3. サブスクリプション1宛先名：キュー：//仮想トピックスコンスマーズ。サブ。マイトピックス