問題タブ [activemq-cpp]

ActiveMQ-CPP 2.2.1 Visual Studio 2005 プロジェクトをコンパイルして実行しています。コンソール ウィンドウでは、メッセージは受信されていませんが、送信されていることが示されます。ActiveMQ-CPP 2.0.1 ではメッセージを送受信できますが、2.2.1 ではできません。私は ActiveMQ を初めて使用し、どこからトラブルシューティングを開始すればよいかさえわかりません。考え/提案/開始するのに適した場所は、大きな助けになります。

役に立ったら、私は ActiveMQ 5.1.0 バイナリを使用しています。

前もって感謝します！

RabbitMQ ブローカー経由でメッセージを送信する必要がある C++ ソフトウェアがあります。RabbitMQ ブローカーにメッセージを送受信するために ActiveMQ CPP lib (CMS) を試した人はいますか?

HornetQ で ActiveMQ-CPP を使用しようとしています。私は ActiveMQ-CPP バンドルの例を使用していますが、それで苦労しています。プロデューサーは魔法のように機能しますが、コンシューマーからは次のメッセージが表示されます。

問題は、キューが存在することです。コードは ActiveMQ+Openwire で問題なく動作しますが、HornetQ+STOMP では同じように動作しません。

何か案は？

ActiveMQ-CPP と stomp プロトコルを使用して永続的なコンシューマーとプロデューサーを作成する際に問題があります。ストンプを使用して HornetQ に接続しようとしていますが、非持続状態でメッセージを送受信できます。メッセージの CMSDeliveryMode とともに配信モードを永続的に設定し、通常のコンシューマーの代わりに DurableConsumer を作成して、プロデューサーを永続的に変更しようとしました。しかし、JBoss JMX-Console を見ると、どちらも非耐久性と見なされていました (メッセージは非耐久性として分類され、コンシューマーも非耐久性としてサブスクライブされます)。

統合テストの StompDurableTest も試してみましたが、20 件のメッセージのうち 10 件しか受信しませんでした (コンシューマーがアクティブなときに送信されたもの)。そのため、テストは失敗しました。

統合テストが機能しなかったため、コードではなく、ActiveMQ-cpp または Stomp の構成に関係していると思います。耐久性を有効にするために何か不足していますか?

前もって感謝します、

サーミ語

重要な場合は、ActiveMQCPP5.2.3を使用しています。

フェールオーバートランスポートを使用してブローカーのJMSネットワークに接続するJMSプロデューサーがあります。connection-> start（）を呼び出すと、ハングアップします（AMQ-2114を参照）。

接続start（）をスキップしてconnection-> createSession（）を呼び出すと、この呼び出しもブロックされます。

要件は、私のアプリケーションがブローカーに接続しようと永遠に試みることです。

提案/回避策はありますか？

注：

これはここでは重複していません。C++や組み込みブローカーなどのソリューションについて話しているので、C++ではSpringを使用できません。

ActiveMQ CPP 5.2.3 を使用しています。

transport.commandTracingEnabled=trueTCPトランスポート層に追加しようとしています:

ActiveMQ はそれを受け入れません。

ただし、1 つの TCP トランスポートでは問題なく動作します。

ActiveMQ 経由でバイナリを含む文字列ストリームを送信することは可能ですか? もしそうなら、これはどのように行われますか？

Activemq の Java バージョンには BlobMessage または StreamMessage と呼ばれる機能があることは知っていますが、これはまだ C++ バージョンには実装されていません。BytesMessage クラスについては既に読んだことがありますが、それを実装する適切な C++ の例が見つかりません。

ありがとう。

私は activemq-cpp を使用しており、BytesMessage を使用してバイナリ データを送信しようとしています。メッセージを送受信するようにプロデューサーとコンシューマーをセットアップしました。トピックにパブリッシュし、消費者が TextMessage を使用してメッセージを取得できるため、接続とセッションは適切に機能しています。接続を確認した後、TextMessage の実​​装を BytesMessage に変更しました。私が今抱えている問題は、BytesMessages をトランスコードし、受信後にメッセージからデータを取得することです。

私のプロデューサーには、次のものがあります。

私の消費者には、次のものがあります。

Producer は正しいサイズの 3 を出力します。しかし、コンシューマーはサイズ 0 を出力します。これは、以前に正しく書き込まれたメッセージを読み取らなかったことを示しています。これにより、私は何が間違っているのでしょうか?

ローカルで読み書きしようとしましたが、まだできません:

書き込み後の cout は 3 を出力しますが、読み取り後の cout はまだ 0 を出力します。

データを正しく書き込んでいませんか？正しい方向のポイントは大歓迎です。ありがとう！

ActiveMQ ブローカーが未使用のトピックをメモリから削除しないという問題が発生しています。

現在、私たちのシステムは、実行時に名前が指定された多くのトピックを動的に生成するように設計されています。これらのトピックは、アプリケーションの存続期間中存在し、その後、トピックのすべてのコンシューマーとプロデューサーがサブスクリプションを解除します。ただし、activemq ブローカーは、これらのトピックをリストから削除しません (Web コンソールから表示可能)。

デフォルトの構成ファイル ブローカーを編集して、persistent="false" および advisorySupport="false" を設定しました。私には、これでブローカーからトピックが削除されるはずですが、明らかに何かが欠けています。

誰でも助けることができますか？

これまでのところ、プリフェッチ サイズを機能させることができません。

私が試してみました：

mySession->createQueue([quename]?consumer.prefetchSize=5);
tcp://localhost:61616?prefetchPolicy.all=5

cms::Connection と cms::Consumers を使用しています。activemq::core に切り替える必要がありますか?

ありがとう