問題タブ [qpid]

最初に私の状況を少し説明します。達成したいのは、複数のプロデューサーと複数のコンシューマー、およびサーバー上の 1 つのブローカーです。メッセージを永続化し、キューを耐久性のあるものにしたいと考えています。互いに干渉しない複数のキューが必要です。キューが 1 つ、プロデューサーが 1 つ、コンシューマーが 1 つで、これは既に正常に機能します。現在のコード:

消費者：

プロデューサー：

もちろん、これらはプログラム全体ではありませんが、Qpid ブローカーに関係するすべてのコードです。

問題は、新しいコンシューマーとプロデューサーを異なるデバイスに作成し、プロデューサーからコンシューマーに移動したい異なるトラフィックがある場合、ProdSevenQueue などの別のキューに送信しても、最初のコンシューマーがブローカーからすべてのデータを盗むことです。 、および他のコンシューマでは、「prodseven_local_Queue」のような別のローカル キューに格納しようとします。どういうわけかキューを別の方法で使用する必要がありますか、それともここで全体のアイデアを誤解していますか? また、broker top を構成して特定の種類のトラフィックを別の場所にリダイレクトすることについて話している人もいますが、この例は見つかりません。右方向へのプッシュは素晴らしいでしょう。さらに混乱させるために、状況の写真を次に示します。imgur へのリンク

私の弁護のために、私はこれまで AMQP や Apache Qpid で何もしたことがなく、まだ Python も学んでいます。また、もう少し不平を言うと、Apache Qpid ほど一貫性のないドキュメントを見たことがありません。明らかに新しいプレーヤーへの愛はありません。

AMQP を介して ActiveMQ と統合する Apache Camel アプリケーションを作成しようとしています。

私は提供された「camel-example-spring-jms」プロジェクトから作業してきましたが、これは標準の TCP 接続を介していますが、TCP を使用して正常に動作している (組み込みではなく) スタンドアロンの ActiveMQ 5.8 インストールを使用するように変更しました。 .

アクティブな MQ 構成 ( 5672 の amqp )

「 camel-server.xml 」内で、既存の「jms」「ActiveMQComponent」を、接続 URL を指定する「AMQConnectionFactory」を参照する「JmsComponent」に置き換えました (以下の両方のバリエーションを試しました)。

サーバーは上記の構成で正常に起動するように見えますが、「ServerRoutes.java」の amqp キューにルートを追加すると、起動時にエラーが発生します。

Camel Server ウィンドウのエラーは次のとおりです。

私のActiveMQウィンドウのエラーは次のとおりです。

この問題を診断するには、どんな助けも歓迎します。

ありがとう。

AMQP 1.0 をキュー ブローカーとしてサポートする ActiveMQ 5.8.0 を使用しています。Qpid AMQP1.0 クライアント jms ライブラリを使用して Java クライアントからこれと通信しようとしていますが、キーストアとトラストストアの情報を指定する方法が見つかりません。

Java VM オプション (-Djavax.net.ssl.keyStore など) を介して SSL 資格情報を渡すことでクライアントを正常に構成しましたが、これは最終的な解決策として受け入れられる方法ではありません...指定できるようにする必要がありますコード内からのこの情報。

現在、createFromURL メソッドを使用して、ここで定義されている SSL パラメーターを含む URL から接続を生成していますが、キーストア情報 (および場合によってはフェイルオーバー パラメーター) が URL から解析されていないようです。

セキュリティ情報を接続に提供するより良い方法を知っている人はいますか?

更新: そうですね、API を掘り下げると、ライブラリがデフォルトの SSLSocketFactory を使用することがわかりました

参照: org.apache.qpid.amqp_1_0.client.Connection

したがって、JVM オプション以外でこの情報を指定してデフォルト値を設定する方法はないようです...少なくとも現在のバージョンの Qpid クライアント ライブラリでは。

現在、Rabbitmq の代わりに QPID を AMQP ソリューションとして使用していますが、Rabbitmq のようにキューとトピックを簡単に確認する方法が見つかりません。

QPID にこれを実行できるツールはありますか? qpid-stat、qpid-tool、qpidd が表示されますが、役に立ちません。利用可能なサンプルまたはドキュメントはありますか? qpid.apache.org にはあまり見つかりません。

ありがとう。

CloudBees が Message Queue サービスを提供していないことは知っています。私の Java EE アプリでは、RabbitMQ をブローカーとして、Qpid JMS をクライアントとして使用しています。次の理由で機能しません。

[#|2013-11-09T20:21:45.203+0000|INFO|glassfish 4.0|org.jboss.weld.ClassLoading|_ThreadID=39;_ThreadName=AutoDeployer;_TimeMillis=1384028505203;_LevelValue=800;| WELD-000119 基礎となるクラスのロード エラーのため、javaeetutorial.websimplemessage.SenderBean から Bean 定義を生成していません: タイプ javax.jms.Message が見つかりません。これが予期しないものである場合は、DEBUG ログを有効にしてエラー全体を確認してください。|#]

CloudBees で動作させるソリューションはありますか。CloudBees は Qpid をサポートしていますか?

前もって感謝します。レオン

まず、この質問をご覧いただきありがとうございます。PaaS (Openshift Origin) で qpid を起動して実行する際に問題が発生しています。

ReST APIを使用せずにサーバーにコピーするだけで、鈍い力の方法を使用して初めて実行します。qpid を実行しようとすると発生するエラーは次のとおりです。

qpid を 127.1.244.129 などの IP にバインドする方法があるかどうか、私はただ興味があります

私が尋ねる理由は、PaaS に多くのインスタンスをデプロイしようとしており、実行中の複数のインスタンスが必要になるからです。すべてが localhost:8080 にバインドしようとする場合、これは不可能です。

これを構成する方法を知っている人はいますか? qpid のドキュメントには見つかりませんでした。