qpid

1熱

1答えて

Python Qpid/Proton/Messenger（）を使用すると、Azureイベントハブからのメッセージをどのようにフィルタリングできますか？

この要点は、Messenger（）を使用してAzureイベントハブからメッセージを受信する方法を示しています。それは素晴らしい作品です。 https://gist.github.com/tomconte/e2a4667185a9bf674f59 しかし、この技術を使用すると、イベントのハブ内のすべてのメッセージを生成します。私は、オフセットまたはタイムスタンプ（どのような気にしないでください）以来

1熱

1答えて

qpidレシーバを設定する方法

私はApache Qpidを使用していますが、例を見ていますが、レシーバを設定して接続が切断されない場合があるかどうかを確認する方法はありませんキュー内の新しいメッセージ

0熱

1答えて

スプリングJMSプロデューサエラー：セッション：ブローカ強制フロー制御でタイムアウト待ちのためメッセージ送信に失敗しました

私は、Spring JMSを使用して、Apache QPIDでメッセージを送受信します。セッション：私は、このエラーメッセージが表示されました原因ブローカーで待機してタイムアウトに失敗したメッセージの送信は何が原因フロー制御を強制しましたか？待ち行列が枯渇しているのでしょうか？どこでキューのフロー制御を設定できますか？ありがとうございました。

-3熱

1答えて

Javaを使用してオブジェクトを抽出する方法

1つのxmlオブジェクトをJMSに送信しています。取得中に私は1つのオブジェクトを受信しています。私は今何を送っているのですか？しかし、それは何でも、XMLでもJSONでもかまいません。 Javaでこのオブジェクトを抽出してXML/JSONを取得する方法はありますか？これは私が書いたonMessage（）関数です。 public void onMessage(Message message)

0熱

1答えて

耐久消費者に接続する - Qpid Proton Python

耐久消費者としてAMQP v1.0よりもActiveMQブローカーを購読するQpid Proton Pythonクライアントを取得しようとしています。私は耐久性のあるサブスクリプションを作成できますが、次回スクリプトを実行したときに同じサブスクリプションを選択する方法を理解していません。各実行後、ActiveMQの管理コンソールには、永続サブスクリプションが作成されたことを示しており、それが私

0熱

2答えて

はSpringBootTest：ブートアプリケーションが

春ブート統合テストは、したがって、この @RunWith(SpringRunner.class) @SpringBootTest(classes = Application) class IntegrationTest { static QpidRunner qpidRunner @BeforeClass static void init() { q

0熱

1答えて

apache camelを使ってquipid consumerをexlusiveにするには？

私は単一のqpidブローカーをクライアントに接続しようとしています。私はこれらの2つのクライアントのうちの1つだけがqpidキューをリッスンする必要があります。私はapache camelでこれを試しています

0熱

1答えて

Apacheのqpidをインストールするときに "エラー：変更の意味"

AMQPメッセージを大規模なC++プログラムに統合するために、SUSE Linuxシステムにqpid陽子0.14.0ライブラリをインストールしようとしています。インストールには "cmake"と "make all"が必要です。『構造体陽子::はdelivery_mode』エラーから『はdelivery_mode』の意味は」変化を研究する Scanning dependencies of ta

0熱

1答えて

QPID Proton-Jはメッセンジャーを非難するが、代わりに何を使うべきか？

私はAMQPの実装としてJavaでApache QPIDを使用しています。私はちょうどMavenのWebサイトが0.15を最新のバージョンとしてリストアップしていますが、バージョン0.16にアップグレードしました。 Messenger APIは、推奨されていないメッセージとして表示されます。 Messenger will be removed from upcoming proton-j rele

1熱

1答えて

qpid陽子on_sendableが一度だけ呼び出される

私はC++でQpid陽子クライアントを実装しています。 Qpidのバージョンは0.12.2です。私はデフォルトのコンテナを実行します。 proton::container(myHandler).run(); MyHandlerという、このようなものです： void MyHandler::on_start(proton::event& e) { proton::connection conn