問題タブ [qpid]

私は以下を実装しようとしています、

• メッセージは、メッセージの優先順位とともにメッセージ ブローカに到着します
• メッセージの優先度に基づいて、さまざまなキューへの道を見つけます

したがって、Q1 には優先度 1 のメッセージがあり、Q2 には優先度 2 のメッセージがあります。

Message Broker プロセス Q1 を他よりも高速にする方法はありますか?

• キュー間で優先度を設定することはできますか?
• Q1 は Q2 よりも優先的に処理されますか、それとも Q1 の処理が他のキューの処理をブロックしますか?
• 交換自体が、他のキューに順番にフィードする優先キューになることはできますか?
• プラグインを介してデフォルトの交換を拡張できることがわかりました。私が持っている上記の要件をすでに実装しているものはありますか?

これは実現可能なものですか？それともメッセージブローカーの基本理念に反するのでしょうか?

優先メッセージを使用する際のベスト プラクティスへのリンクはありますか?

私は 8 月 28 日に Qpid nabble フォーラムにこのメッセージを投稿しましたが、「この投稿はまだメーリング リストに受け入れられていません」。

お時間をいただきありがとうございます。

Apache Qpid、Cmake、Python は初めてです。Debian で Qpid を正常にビルドし、いくつかのテストを実行しました。現在、C# クライアントを記述できるように Windows で Qpid を構築しようとしていますが、何か問題があるようです。cmake コマンドを実行すると、次の出力が表示されます。

setup.py がいつ生成/ダウンロードされるべきかを理解しようとしています。私はそれを見つけることができず、いつ生成またはインストールされるべきかを説明するドキュメントも見つかりません。また、ややトピックから外れていますが、cmake プロセスが BUILD_ACL やその他の構成を要求し始めたのはなぜですか?

次のコマンドを使用して、VS 2008 と 2010 の両方で cmake を実行しましたが、どちらも同じ出力が得られます。

Apache の次のファイルを使用して Qpid をビルドしています: qpid-cpp-0.18.tar.gz

上記のログ ステートメントからわかるように、私は Python 3.3.0 を使用しています。

setup.py は、Python がコンポーネントをインストールするために使用するファイルであることを理解しています。cmake スクリプトは、setup.py を検索して見つけた cmake スクリプトの一部に基づいて、tests ディレクトリに何かをインストールしようとしているようです。これは、Qpid tarball で提供されるか、この cmake プロセスの一部として生成されるものだと思います。

そうは言っても、cmakeのすべてのデフォルトを受け入れてエンターキーを押し続けると、ソリューションファイルとプロジェクトファイルが生成されました。結果の Qpid ソリューションを VS2008 で開き、いくつかのプロジェクトをビルドすることができました。では、なぜ setup.py が必要なのかという疑問が生じます。

Qpid ブローカーのストレージとしてDerby DBを使用しています。組み込みデータベースとして実行しているときに、Derby がデータ ファイルを格納する場所を把握しようとしています。

ファイルがどこにあるか、または使用するディレクトリを設定する方法を知っている人はいますか?

Apache Qpidをアーキテクチャに実装しようとしていますが、プロパティファイルの読み取りに問題があります。

プロパティprops=new Properties（）; props.loadFromXML（this.getClass（）。getResourceAsStream（ "hello.properties"））;

loadfromxmlがエラーをスローしています。スタックトレースは次のとおりです。

hello.propertiesファイルは次のとおりです。

私は何が間違っているのですか？Qpidのドキュメントページからコードスニペットをコピーしました。

私には1つのプロデューサー、1つのキュー、およびNのコンシューマーがあります。プロデューサーは、コンシューマーによって実行される「ジョブ」を作成します。消費者が前のジョブを終了するときに、消費者がキューからジョブをプルするプルモデルを使用したいのですが、ラウンドロビンを使用したプッシュモデルではなく、ジョブが消費者に等しい分数で除算されます。

私の消費者は同じコードを使用していますが、私がそれを実行すると、最初のコードが接続してすべてのジョブを受け取ります。デバッグでそれを見ても、最初のものはすべてを取得しますが、2番目のものなどはメッセージを取得しません（最初のものが受信を実行する前に受信を実行した場合でも、いくつかのジョブが返されます）。

接続URL： "amqp：// guest：guest @ prodconstest /？brokerlist ='tcp：//127.0.0.1：5767'"

すべての消費者のためのコードは次のことを行います。

1. AMQConnectionを作成します
2. 自動ACKでキューセッションを作成します
3. 接続開始
4. キューを作成"ADDR:" + queueName + "; {create: always, link:{x-subscribes: {exclusive: false}}}"
5. 消費者を作成する

AMQPキューを使用して達成することは理論的に可能ですか？もしそうなら、どのように？

wiki ページhttps://cwiki.apache.org/qpid/amqp-java-jms-messaging-client.htmlからhttps://cwiki.apache.org/qpid/connection-url-format.htmlへ。

シンプルに qpid-amqp-1-0-client-jms-0.20-sources.jar が URI 形式を受け入れることを期待していましたが、ほとんどすべてを無視しているように見えます-特に「brokerlist」オプション?

例えば：

ただし、ConnectionFactory は をブローカー ホストとして使用することを主張し<clientid>、それにデフォルト ポートを追加します。

ここで本当に明白な何かが欠けていると確信しています...

ブローカーは ActiveMQ 5.8.0 です。

WSO2 MB 3.2.1 と共に RabbitMQ 2.8.7 DotNet クライアントを使用しています。私の展開環境は、Win7 R1 64bit または Win Server 08 R2 64bit です。Exchange への複数の接続で、複数のコンシューマーにストリーミングされるデータが断続的に失われるという問題が発生しました。WSO2 MB を 3.2.3 に更新し、交換をファンアウトに変更してこの接続の損失を解決しようとしましたが、問題が発生しました。

このリンクが多少関連しているように「見える」でしょう：

http://wso2-oxygen-tank.10903.n7.nabble.com/Qpid-Authorization-handler-does-not-allow-to-subscribe-td2080.html

これが正しいアプローチであるかどうかを最初に知りたかったのです。

次に、データにアクセスできないため、ファンアウトを使用して実行時に受け取る現在のエラーを理解したいと思いました。以下は、受信したエラー、WSO2 MB ログ出力、およびプロデューサーからのコード スニペットです。

特定するためにさらに情報が必要な場合はお知らせください。

エラーが発生しました...

ログ@エラーの時間...

この問題は、Java に接続しようとしたときにも発生することがわかりました。プロデューサーの C# コードの簡単な例を以下に示します。

make file を使用せずに Apache qpid C++ ブローカーで helloworld の例を実行したいのですが、それは可能ですか?

svn checkout で apache qpid をインストールしようとしていますが、make の実行中にすべてのツールをインストールしましたが、エラーが発生しました

svn co http://svn.apache.org/repos/asf/qpid/trunk

Qpid 0.20 CPP ブローカー (AMQP 1.0 準拠) を実行しており、Java アプリケーションで JMS メッセージを送信しようとしています。

• 機能しているのは、AMQP 0-10 クライアントとorg.apache.qpid.jndi.PropertiesFileInitialContextFactoryクラスが使用されている場合です (最初の Java の例を参照)

• 機能しないのは、AMQP 1.0 クライアントとorg.apache.qpid.amqp_1_0.jms.jndi.PropertiesFileInitialContextFactoryクラスが使用されている場合です ( 2 番目の Javaの例を参照)。クライアントはエンドレス スレッド ループに入り、実際にはメッセージを送信しません。

Windows Azure のドキュメントではクラスの使用について明示的に言及されているためorg.apache.qpid.amqp_1_0.jms.jndi.PropertiesFileInitialContextFactory、Qpid 0.20 CPP ブローカーは AMQP 1.0 Java クライアントをサポートしていない可能性がありますか? AMQP 1.0 の例の接続 URL ( http://guest:guest@localhost/test?cliendId='test-client') が無効であるため、コードが実行可能かどうかはまったくわかりません。

設定 CPP ブローカー - Java AMQP 1.0 クライアントが本当に機能するかどうかは誰にもわかりませんか?