問題タブ [spring-integration-amqp]

質問する

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

70 問題
Newest
Active
Bountied
318
Unanswered
0 投票する
1 に答える
53 参照

spring-integration-amqp - 例外時の送信 Amqp アダプター ロールバック メッセージ

メッセージを転送するために春の統合（インバウンド/アウトバウンドチャネルアダプターを使用）を使用しています

  • JMS から AMQP
  • AMQP から JMS
  • AMQP から AMQP

これはうまくいきます。

宛先キューがいっぱいになったら、プロセスを停止し、メッセージを元のキューに送り返したいと思います (チャネルからのロールバック メッセージ)。

これは、JMS => AMQP および AMQP => JMSでは正常に機能しますが、AMQP => AMQP では KO になります。

次のコードは正常に動作します (JMS => AMQP)

ログ ファイルでは、メッセージはよくロールバックされます。

正常に動作する AMQP=> JMS の同様のコードがあります。

しかし、AMQP => AMQP の場合、問題があり、メッセージが失われ、プロセスが停止しません。

ログファイル:

そして、メッセージを停止してロールバックする代わりに、コンシューマーを再起動します。

その後、私のメッセージは失われます:- (

この特定のケースで期待される操作を行うための推奨事項はありますか? 特定の治療法を追加する必要がありますか?


12345678910