問題タブ [spring-rabbit]

初期状態: ウサギには 1 つのコンシューマが接続されています

イベント: ウサギと消費者の間のネットワーク接続が切断されました

結果: コンシューマーは Rabbit に再接続しようとしていますが、Rabbit のコンシューマー リストにはコンシューマーが含まれています。

次のイベント: ネットワーク接続が再びアップし、消費者は Rabbit に再接続しますが、以前の Rabbit 接続は消えません。

結果: ウサギが非アクティブなコンシューマにメッセージを送信しようとしています

質問: コンシューマーがまだ利用可能かどうかを自動的に確認し、そうでない場合はリストから削除する可能性はありますか?

ハートビート オプションはオンになっていますが、問題は解決しないことに注意してください。

使用ライブラリは次のとおりです: 使用ライブラリ org.springframework.amqp:spring-rabbit:1.2.0.RELEASE com.rabbitmq:amqp-client:3.2.1

返信先機能をサポートする spring-amqp 上のコンテナーが存在しますか?

https://www.rabbitmq.com/tutorials/tutorial-six-java.htmlのような RPC を作成したいのですが、spring-amqp を使用しています。

単一の rabbitTemplate インスタンスがあり、 rabbitTemplate.send（Message） を呼び出してメッセージを RabbitMQ サーバーに発行するとします。

ここでやりたいことは次のとおりです: 1. パブリッシャー ビューから、メッセージが RabbitMQ によって確実に受信されるようにする方法 2. コンシューマー側では、同じ rabbitTemplate を使用してスレッドでメッセージを受信し、他のスレッドでメッセージを手動で確認したいと考えています。

RabbitTemplate でメッセージを手動で確認する方法はありますか?

助けてくれてありがとう。

I am using spring-rabbit1.1 and RabbitMQ 3.3.1 ,

My spring configuration will create any queue with the help of RabbitTemplate on Rabbit MQ but if the queue has been configured with x-dead-letter-exchange and x-message-ttl , it just creates the queue with out the TTL and dead letter exchange.

For Eg : the below queue will create the queue but TTL and dead letter exhange is not getting created .

So i had to go and delete the queue from Rabbit MQ and create with all the required values manually to make it work .

Can anyone help me if there is any option to solve this issue ???

現在、再試行を処理するために spring-retry を使用するようにメッセージ リスナー コンテナーを設定しましたが、誰かがメッセージ ID を指定せずにメッセージを送信すると、メッセージ リスナーが停止します。リスナーを停止する代わりにメッセージを配信不能キューに入れるように、この動作を変更できますか?

再試行の構成は次のとおりです。

次の例外が発生します。

そのため、後でメッセージ リスナ コンテナを停止し、代わりにメッセージをデッドレター キューに入れるという事実を変更したいと思います。

クルグズ