問題タブ [qpid]

QPID の使用を開始する方法について、リンクを共有できますか?

チェックアウトしましたhttp://qpid.apache.org/で、Java QPID ブローカーを開始できましたが、ここからどこに行けばよいかわかりません。

Java または C# でブローカーを使用し、相互にメッセージを送信するためのサンプル アプリが 1 つまたは 2 つあれば、それは素晴らしいことです。

そうでない場合は、誰かが私を正しい方向に向けて、QPID を使い始める方法に関するリンクやドキュメントを提供してくれるかもしれません。

ありがとう

スタンドアロンのjunitテストでApache Qpidを使用した例はありますか?

理想的には、テスト内でメッセージを送受信できるキューをオンザフライで作成できるようにしたいと考えています。そのため、テスト内で QPid をテストしていません。そのために統合テストを使用しますが、サービスの負荷をモックアウトする必要があるメッセージを処理するメソッドをテストするのに非常に役立ちます。

Qpidをビルドしようとしています。CMake を実行すると、これがログに出力されます。

生成されたはずのファイルが見つからなかったため、失敗しているようです。しかし、Ruby を見つけることができなかったので、そうではありません。

RUBY_*しかし、RUBY_EXECUTABLE や RUBY_INCLUDE_DIR などの他の変数が CMake で設定されているため、少なくとも部分的に Ruby を見つけているようです。

RUBY_LIBRARY とは何ですか? また、何に設定する必要がありますか? Ruby は C:\Ruby192 にインストールされます。

最初は QPID のドキュメントは素晴らしいと思っていましたが、今ではわかりにくいと感じています。qpid::messaging名前空間で QPID-0.6 の C++ API を使用しています ( qpid::clientを使用して低レベルの AMQP にアクセスできることがわかりましたが、今は望んでいません)。

AMQP では、型で交換を宣言し、メッセージを送信する前にキューとバインディングを宣言します。QPID を使用すると、送信先の送信者に 1 つのアドレスを指定できます。同じことを行うアドレスの例を含むドキュメントはありますか? （さまざまな交換、キューを作成し、バインディングを作成します）。

特に、node、link、x-declare、および x-binding フィールドを含む Address 構文をオンラインで見つけました。しかし、0.6 のコードを掘り下げても、これは見つかりませんでした。代わりに、より単純な構文 (node-properties および x-properties という名前のフィールドを使用) が見られます。また、そのドキュメントはあまり単純ではなく、例もありません。

examples/messaging/client.cpp で、これは私が見つけたほとんどのものです: #response-q; {create:always, type:queue, node-properties:{ x-properties:{auto-delete:true}}}

• この単純なアドレス構文を使用して、さまざまなタイプの交換、キュー、バインディングを設定できますか?

• それとも、0.6 以降のものに移行するのが望ましいでしょうか? （それが十分に安定していて、厄介な構文が少ない場合）

• または、私のアプローチが間違っているので、高レベル API を使用して交換用のレシーバー キューを事前に作成してバインドする必要はありませんか?

ありがとうございました。

QPidをJMSプロバイダーとして使用しようとしています。Mavenはビルドツールとして使用されます。QPidを含むMavenリポジトリが見つからないため、ビルドが失敗します。

質問

1. 誰かがqpidを含むmvnリポジトリを知っていますか？
2. 回避策はありますか？すべてのJARファイルをダウンロードし、それらを.m2 / repository / org / apache / qpid / qpid-common/0.6および.m2/repository / org / apache / qpid / qpid-client/0.6に配置しようとしました。

しかし、ビルドはまだ失敗します。私はそれに取り組むのに十分なMavenを知らないと思います。それで、解決策は何ですか？

この例では、Apache Camel と Apache CXF を使用しています。

http://camel.apache.org/better-jms-transport-for-cxf-webservice-using-apache-camel.data/cxfcamelexample.zip

JMS の代わりに AMQP を使用したいのですが、構成がわかりません。また、誰かが助けてくれる場合は QPID クライアントのバージョンを変更する必要があります。これは素晴らしいことです。

最近、メッセージングを実装する必要があるプロジェクトに取り組み始めました。実行可能なオプションは次のとおりです。Apache QpidまたはRabbitMq、私のタスクは次のとおりです。

+A+ >>.[Millions Devices (Producers) -- Connected to -- Messaging Server (Clustered -- Qpid or RabbitMQ) ] { 負荷分散)

その後

+B+ >>.[メッセージング サーバー (クラスター化 -- Qpid または RabbitMQ) -- 接続先 -- ゲートウェイ サーバー (クラスター化) ]

その後

+C+ >>.[GateWay サーバー (クラスター) -- 接続先 -- Internet Explorers/Browser (Consumers) ]

+A+ を参照 >>-- 通常は負荷分散のためにメッセージングを使用する必要があり、その後、ゲートウェイ サーバーが生成されたデータを消費者 (ブラウザー) に中継します。

いくつかの負荷分散アルゴリズムを使用して、Broker 内に複数のキューが作成されることを意味します。プロデューサー (デバイス クライアント) -- メッセージのデータを特定のキューに送信し、ラウンド ロビンまたは他の一般的な負荷分散アルゴリズムに基づいてキューに配信します。配信を保証するために Ack も必要になる可能性があり、次にコンシューマーがメッセージを選択しますキューに入れ、さらにリレーします。すべて非常に標準的なものです。

私は AMQP の基礎を学び、Qpid と RabbitMQ の両方の基本的な例を実行しました。ここに私の質問があります:

• RabbitMQ または Apache Qpid のいずれかを選択する方法、またはいくつかの実験または何かを提供できるものはありますか?

• 多かれ少なかれ同様の要件に取り組んだことがある人はいますか? そして、彼/彼女はそれについて何かコメントを提供できますか? または実際にアルゴを実装する前のいくつかの指針、生産者と消費者の実装？

• 私のプロジェクトは何百万ものデバイスがメッセージングサーバーに接続されていることを期待しているため、私の全体的な要件は負荷分散に関連しています。後でメッセージングデータが中継され、現時点でApache QpidまたはRabbitMQを選択するための大きな混乱があり、両方とも同じように見えます

Apache qpid-cpp メッセージング API は、ActiveMQ のようにメッセージの遅延配信をサポートしていますか?

Qpid / AMQPで自分からのメッセージを無視する方法はありますか？qpidのドキュメントとソースの両方を調べましたが、それらを無視できるフラグが見つかりません。exchangeBind（）に渡されるもののようです。