問題タブ [activemq-cpp]

同じプロセスの異なるスレッドで実行したいと思いcms::MessageConsumerます。cms::MessageProducer

これを安全に行うにはどうすればよいですか？

安全性を保証するには、2つのcms::Connectionオブジェクトと2つのcms::Sessionオブジェクト（それぞれ消費者と生産者用）があれば十分でしょうか？これは必要ですか？

このタイプの使用を妨げる静的ライブラリレベルのオブジェクト間で共有状態がありますか？

トピックごとに個別のセッションを作成して、同じ接続内に複数のトピックを作成しようとしています。トピックと最初の耐久性のあるコンシューマーの両方が正常に作成されましたが、2 番目のコンシューマーの作成中にエラーが発生しました。コードは単一のトピックで完璧に機能しますが、実行時に同じ接続内で複数のトピックを作成する必要があります

以下はコードです

------------ 変数値 --------------

applicationId = "Test123"

getSelector(0) = "CID は 'Test123' のようではなく、耐久性は '0' のようです"

ActiveMQ サイトのこの構成ページによると、connection.sendTimeoutプロパティは次のとおりです。

Message Sends for a Responseを待機する時間。デフォルト値のゼロは、永久に待機することを示します。このクライアントが高速なプロデューサである場合、またはプロデューサの速度を落とさなければブローカがメモリ不足になるようなコンシューマがない場合、永久に待機することで、ブローカはこのクライアントからのメッセージをフロー制御できます。送信はブローカーによって確認されるため、Stomp クライアントには影響しません。(ActiveMQ-CPP 2.2.1 以降)

私はこれが何を意味するのか（そしてsendTimeoutプロパティが実際に何であるか/それが何をするのか）を解釈するのに苦労しています：

• 「メッセージ送信」オブジェクトとは何ですか?
• ActiveMQ が応答を待っているのはなぜですか? JMS 接続のサーバー側ではありませんか? リクエストを待つべきではありませんか？
• 実際にタイムアウトするのは何ですか？いつ使用する必要がありますか？

前もって感謝します！

I am using ActiveMQ-CPP 3.4.5 to connect from C++ program to message broker. The problem I encountered is connected with redelivery policy. Messages which are returned to queue are redelivered immediately. This is not the behaviour I expect. I would expect the messages to be returned after certain period of time which is set through redelivery policy.

This is a code snipped showing the way I set up redelivery policy:

As I said before I would except the messages to be redelivered after 10000 ms, but the are not. They come back to consumer immediately.

Does anyone know what could be the reason of such behaviour?

activemq のキューのコンシューマーとして機能するアプリケーションがあります。このアプリケーションは c++ で作成され、activemq-cpp を使用して activemq のサービスを取得します。

私が達成したいのは、アプリケーションがダウンして再び起動したときです。アプリケーションがダウンしている間にキューに取り込まれたすべてのメッセージを最初に削除する必要があります。つまり、最初にキュー内のすべての古いメッセージを削除してから受信を開始する必要があります新しいメッセージ。

activemq-cpp を使用してこれを達成する方法はありますか?

私は activemq 設定で priorityedMessages を有効にしました。優先度は正常に機能します。つまり、X メッセージを送信すると、半分は優先度 0 で半分は優先度 9 で、消費者はメッセージを正しい順序で受信します。

CMSPriority > 0ただし、またはなどのセレクターを使用して createConsumer() メソッドを呼び出すと、CMSPriority < 4メッセージが受信されません。

関連する消費者コードは次のとおりです。

最後の行を に変更するとmConsumer = mSession->createConsumer(mDestination);、すべてのメッセージが正しい優先度で受信されます。

誰でもこの動作を説明できますか?

特定のメッセージが何回再配信されたかを知る方法はありますか?

getCMSRedelivered()classのメソッドがありcms::Message、問題なく動作しますが、ブール値を返します。getRedeliveryCounter()classのメソッドもありますがactivemq::core::commands::Message、直接アクセスしたくない内部クラスです。

ありがとう。

AFAIK getDestinations は ActiveMQ-CPP API に実装されていません

C++ API を介してブローカーに追加されたすべての宛先のリストを取得する方法はありますか?