qpid

0熱

1答えて

現在、私は単一のキュー "devQueue"にメッセージを送信できます。メッセージが「devQueue」に届くと、それは「localQueue」にも送られる必要があります。私はこの実装が挑戦的であると感じています。私は別のクラス "local_send"を "class1"クラスから呼び出そうとしましたので、 "localQueue"（下のコードに示すように）の他の行き先に接続できますが、運があり

0熱

2答えて

Qpidプロトン：idle_timeout設定

私はQpid Proron 0.18.1バージョンを使用しています。 idle_timeoutは、 connection.idle_timeout() : 15000のように出力されています。私はデフォルト値15000が設定されているコードに戻ってトレースすることができません。また、コンテナ内で次のように変更しているとき： c.connect(conn_url, co.idle_timeout(p

0熱

1答えて

QPID JMSを使用してazure servicebusからのトピックサブスクリプションからのメッセージを受信

私はこのサブスクリプションからのメッセージを読むためにtutorialに従っています。このprogramIを実行するには public class Receive implements MessageListener{ private static boolean runReceiver = true; private Connection connection;

0熱

1答えて

待機中ではなく、Qpidプロトン接続からすべてのメッセージをフラッシュしますか？

プロトンは、複数のプロトンメッセージを同時に送信することにより、より効率的に帯域幅を使用する「バンドリング」と呼ばれる機能をサポートしています。私は待っているのではなく、すべての現在のメッセージをフラッシュしたいと思います。これはどうすればいいですか？これは、0.17バージョンのC++ APIを使用しています。

0熱

1答えて

log4jのログ

を書いていないことは以下の私のlog4j設定 #log4j.additivity.org.apache.qpid=false log4j.rootLogger=DEBUG, console log4j.appender.console=org.apache.log4j.ConsoleAppender log4j.appender.console.layout=org.apache.log4

0熱

1答えて

AMQP1.0ブローカからのメッセージをSpring-AMQPに接続して処理することができます

spring-amqpはAMQP 1.0のバージョンをサポートしていないため、AMQP 1.0ブローカと通信できますか？私は使用する予定のQPID Proton APIについて知っていますが、AMQP1.0に接続するにはSpring提供のソリューションを使用することをお勧めします。

0熱

1答えて

JMS接続がJMSSecurityExceptionをスローしない不正なルートにメッセージを送信するとき

Javaサービスからメッセージを送信するためにSpringでApache Camelを使用しています。交換時にエラーが発生した場合、特定のイベントを処理/トリガーする必要があります。私は私の目的を達成するために以下のコードを使用しています。私は間違ったルート名broadcast.SIMULATOR.ROUTE1、エンドポイントの値を設定しテストするために try { prod

0熱

1答えて

JMS QPIDキューとトピック

JMSキュー/トピックに関しては混乱します。私が望むのは、すべての加入者にメッセージを送り、加入者がアクティブになったときに非アクティブな時間からメッセージを受信したいということです。しかし、私は加入者が永続的な加入権を持っているかどうかを制御できません。永続的なキューを設定し、すべてのサブスクライバが同じメッセージを受信できるように設定する方法はありますか？そして、スプリング設定を使ってこれを設

7熱

1答えて

qpid特定のサブスクリプション（トピックのサブスクリプション）からメッセージを受信するためのプロトンURL

サービスバスからサブスクリプションメッセージを読みたい。私はqpid-protonのPythonライブラリを使用しています。私はメッセージProton-Python-Example-Simple-Receiveを受け取るためにこのリンクをたどっています。私は、サービス・バスからメッセージを受信するために、このURLを渡しています - url = 'amqps://mynamespace.servi

0熱

1答えて

Apache Qpid GUIはどこでディスクを変更しますか？

なしでQpid のポートインターフェイスを削除しようとしています。ブローカ管理GUIを使用しています。 GUIを使用して手動で変更すると、ポートが削除されたときに（diffから）config.jsonが変更されていることがわかります。私のコードソリューションではsedを使用して、必要な行をconfig.jsonから削除します。これは意図したとおりに動作しませんが、私は別のファイルを変更する必要