2017-06-26 6 views
0

現在、クライアント間でさまざまなメッセージを送受信するJMSソリューションとしてApache ActiveMQを使用しています。特定のクライアント(コンシューマーまたはプロデューサ)の稼働時間を確認したいのですが、これまでにこれを行う方法は見つかりませんでした。私はアドバイザリメッセージとStatisticsPluginをチェックし、これを行う方法についての情報はありませんが、役に立たないことは何も見つかりませんでした。ActiveMQ(Java) - 接続がアクティブな時間(コンシューマまたはプロデューサ)を確認する

ConsumerクラスとProducerクラスにクロックを埋め込み、これらのクラスから時間を取得するためのメッセージを送信するための特別なアドバイザリを作成することができます。しかし、これは実用的ではないようです。

誰かがActiveMQでこれを行うためのより良い解決策または方法を知っていますか?

答えて

0

なぜアドバイザリは解決策ではありませんか? トピックActiveMQ.Advisory.Connectionのメッセージを待ち行列にルーティングすることで、このように使用して、稼働時間を計算して稼働時間を計算することができます。

諮問トピックからキューにメッセージを送信あなたのactivemq.xmlに

... 
    </broker> 

    <!-- configure the camel activemq component to use the current broker --> 

    <bean id="ActiveMQVMConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory"> 
     <property name="brokerURL" value="vm://localhost?create=false&amp;waitForStart=10000"/> 
     <property name="userName" value="${activemq.username}"/> 
     <property name="password" value="${activemq.password}"/> 
    </bean> 
    <bean id="activemq" class="org.apache.activemq.camel.component.ActiveMQComponent" > 
     <property name="connectionFactory" ref="ActiveMQVMConnectionFactory"/> 
    </bean> 

    <camelContext id="camel" trace="false" xmlns="http://camel.apache.org/schema/spring"> 
     <route> 
      <from uri="activemq:topic:ActiveMQ.Advisory.Connection" /> 
      <to uri="activemq:queue:Advisory"/> 
     </route> 
    </camelContext> 
+0

をこのスニペットを追加し、それが稼働時間を得ることができることだ、私がいる問題ではありません。どうすればいい?私が逃した何らかの機能がありますか、別の方法を使用すべきですか?編集:私はまた、XMLだけ、Javaを使用していないと言及する必要があります。 –

+0

接続が開始または停止するたびに、情報がActiveMQ.Advisory.Connectionというトピックにメッセージが送信されます。稼働時間を計算するクライアントが接続されていない場合はメッセージが失われ、後で処理するためにメッセージをキューに送信するように提案しました。起動メッセージと停止メッセージの時間の差を計算すると、稼働時間はありませんか?組み込みActiveMQを使用していますか?プログラムでキャメルルートを作成するか、またはJavaリスナーを埋め込むことができます。 –

+0

これは良い考えですが、問題は「アドバイザリ」プログラムがオフラインであっても稼働時間を計算することです。ユーザーはメッセージを送受信できます。何時でも、最初の接続情報メッセージを受け取るためにプログラムを開いたままにしなくても、接続の稼働時間を確認できます。私は時計のアイデアにこだわりたいと思います。それは、消費者とプロデューサーがすでに購読しているトピックやキューと同様に、アドバイザリメッセージを管理する余分な接続を開かなくても、正確に動作させる方法を見つけ出したからです。 –

関連する問題