2016-05-09 10 views
0

ActiveMQ ServiceMixと私はエンキューされたメッセージ数/デキューメッセージ数などをJavaで処理したいと思います。それはActiveMQのコンソールにActiveMQエンキューメッセージjava servicemix karafコマンド

Name Number Of Pending Messages  Number Of Consumers  Messages Enqueued  Messages Dequeued  Views  Operations 
Consumer.ID-10-147-244-247-15461c6c293-38-0.Vir... 0 2 13 13 
Consumer.ID-10-147-244-247-15470570c61-108-0.Vi... 0 2 13 13 

を示しているように私は、私はメッセージが列をエンキュー取得したい値をしたい:)

私のプログラムは、消費者とリスナーのとのセッションを開始します。すべて正常に動作します。

しかし、監視のために、私は私はこの試みる私のサブスクリプションでは、私のサブスクリプション・オブジェクト(サブスクリプションcontaintセッション/接続/キューなど...)

を呼び出すkarafコマンドを書いている:

ActiveMQConnection activeMQConnection = ((ActiveMQConnection) connection); 
ActiveMQQueue activeMQQueue = getQueueConnection(queueName, activeMQConnection); 

ActiveMQTopic a = AdvisorySupport.getConsumerAdvisoryTopic(activeMQQueue); 
を私はtは私のキュー/トピックに関するすべての情報を取得するために DestinationStatisticsを取得する方法を知っているドン

が、次の...

は、私もこれを試してみてください。

QueueBrowser queueBrowser = session.createBrowser(activeMQQueue); 

ブラウザでは何も表示されません。

誰かが私のDestinationStatisticsがobjetct得るために私を助けることができるならば、多くの

答えて

0

おかげでFinaly私はQueuBrowserはちょうどので、私は繰り返すことができ、それらを削除せずにキューをブラウズし、キューの長さを知るためのQueueBrowserを使用します任意のキュー内のメッセージの数をカウントします。

関連する問題