メッセージ数を数えるには、特定のActiveMQキューのコピーを一時的にコピーしますか? -- jms フィールド と activemq フィールド 関連 問題

Make temporarily copy of specific activeMQ queue to count the number of messages?












-1
vote

問題

日本語

メモリ制約により、ActiveMQはキューのスナップショットを返し、繰り返しのすべてのメッセージを保証するものではありません。

特定の値と一致するプロパティの1つをすべてのメッセージをカウントするために、キューのコピーを作成することを考えました(メッセージを消費せずに)。一時的なコピーが行われると、この一時キューからメッセージの消費を開始し、プロパティに一致するすべてのメッセージをカウントできます。このようにして、元のキューは影響を受けません。

それからメッセージを消費することなくキューのコピーを作成することは可能ですか?その欠点はありますか?

ミラー化されたキュー、仮想トピック、および複合宛先は、すべてのメッセージを別のキューに転送し、既存のキューのコピーを作成しないので役に立ちません。

英語

Due to memory constraint, activeMQ only returns a snapshot of the queue and does not guarantee all the messages while iterating over it.

In order to count all the messages, with one of it's property matching a specific value, I thought of making a copy of the queue (without consuming the messages). Once a temporary copy is made, I can start consuming the messages from this temporary queue and count all the messages matching the property. This way the original queue will remain unaffected.

Is it possible to make a copy of an queue without consuming messages from it? Are there any drawback of it?

Mirrored queues, Virtual Topics and Composite Destinations would not be helpful as it would forward all the messages to another queue and not make copy of an existing queue.

</div
     

回答リスト

0
 
vote

このアプローチは、あなたが望むものを考えると、 jolokia powered REST APIを使用してMBeanにアクセスできます。

JMXに対してデッドセットした場合は、 statistics broker plugin を活用できます。ブローカー統計にアクセスするためのAPIベースのAPI。

 

This approach seems rather overkill given what you want is simply to get a count of the messages in the queue which is easily achievable using the JMX MBeans for the Queue statistics. You can access the MBeans using the Jolokia powered Rest APIs as well.

If you are dead set against JMX then you could leverage the statistics broker plugin to allow a message based API to access broker statistics.

</div
 
 
     
     

関連する質問

2  リモートマシンからのGrails ActiveMQへのアクセス  ( Accessing grails activemq from remote machine ) 
私はJMS Stuffに新しいものです。 ActiveMQが埋め込まれたマシンAでホストされているGRAILアプリがメッセージを送信できるようにするシステムを構築しようとしています。 JMSプラグインだけでMachine Bでホストされている別のGrail...

6  ActiveMQConnectionFactory SendTimeout  ( Activemqconnectionfactory sendtimeout ) 
connection.sendTimeout < connection.sendTimeout < / CODE>プロパティは: メッセージの送信応答の場合、を送信する時間、デフォルト値ゼロのゼロは永遠に待つことを示します。永遠に待って、ブローカーはか...

1  ActiveMQトピックのワイルドカードが働いていません  ( Activemq topic wildcards not working ) 
トピックの authorizationEntry エントリを正しく入力する方法を理解しようとしています。私はこのページの詳細を読みました[ワイルドカード構文] [1] ActiveMQ 5.14.3はDockerコンテナとして実行されています 今の時点で、...

15  C#でのメッセージングに使用するもの  ( What to use for messaging with c sharp ) 
だから私の会社はFoxProデータベースに全部のデータを格納し、それを直接触れることの能力のヒットを回避しようとしていました。私は activemq を見始めましたが、C#とどのようにフックするかわかりません。みんなが考えていることを聞きたい。 編集:Webア...

2  ActiveMQ管理コンソールのログアウト/セッションタイムアウト  ( Activemq admin console logout session timeout ) 
activemq 管理コンソールのログアウトの方法はありますか? また、管理コンソールにログインしたら、一度の非アクティブの後にセッションタイムアウトを作成する方法はありますか? 管理者WebAppの web.xml でセッションタイムアウトを変更しよう...

1  ActiveMQでのパフォーマンスがヒットします  ( Performance hit in activemq ) 
春に基づくアプリケーションで次のようにして顕著なパフォーマンスが向上しています。 <事前> <コード> Destination destination; destination = new ActiveMQQueue(someFunctionArgumentS...

3  EJBException:プールセマフォの取得に失敗しました  ( Ejbexception failed to acquire the pool semaphore ) 
いくつかの異なるメッセージ駆動型Beanには、次のEJB例外が発生しています。 <事前> <コード> javax.ejb.EJBException: Failed to acquire the pool semaphore, strictTimeout=100...

1  Apache Camelマルチキャストテキストメッセージをバイトメッセージに変換する  ( Apache camel multicast converting text message to byte message ) 
ApacheMQを使用してApache Camelを使用してテキストメッセージをトピックに公開しようとしています。 次のコードは問題になり、私のクライアントプログラムはメッセージをテキストメッセージに変換することができます。 <事前> <コード> <...

1  PHPアプリの非同期/エンタープライズメッセージング  ( Async enterprise messaging for php apps ) 
PHPとJavaアプリ間の非同期メッセージキューイング(公開、消費)に最適なメッセージングプラットフォームが最適ですか?私はRabbitmq、ActiveMQ、Openamq、Tibco Rendezvous、およびWebSphere MQを見ました。持続性...

-1  ActiveMQ:ActiveMQ.Advisory.Connectionトピックのサブスクライバを作成する方法  ( Activemq how to create subscriber for activemq advisory connection topic ) 
クライアントが接続または切断されたような異なるイベントのための ActiveMQバージョン5.4.3 のアラートを書きます。しかし、私は続行できず、 ActiveMQ.Advisory.Connection トピックのサブスクライバを作成できません: <事前>...




© 2022 cndgn.com All Rights Reserved. Q&Aハウス 全著作権所有