私はスプリングブートAMQPライブラリを使用して、スプリングブートアプリケーションを用意しています。Spring-Boot/AMQP - 処理されるメッセージの上限数
のpom.xml：
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
は、どのように私はそれが終了優雅にそして単一メッセージを処理し、承認することができますか？
通知なしで終了することはできますが、メッセージを確認してから終了する方法がうまくいかないようです。
リスナーコンテナを使用する代わりに、RabbitTemplate.receive()（またはreceiveAndConvert()）のいずれかのメソッドを使用するだけです。
これは消費者がメッセージを聞いてくるのではなく、リクエストに基づいてメッセージを聞き取ることです - いいアイデア – ManseUK
はい、まさにそうです。それがオンデマンドで消費する最も簡単な方法です。 –
あなたは、以下の手順に従うことができます：
RabbitListenerリスナーとしてAtomicIntegerを宣言します（完全例えばthis SO answerを参照してください）あなたはメッセージを聞きます（つまり、listenメソッドは例外なしで実行されます）。カウンタの値を超える0（または設定された閾値以上）であれば、メソッドが正常にincrementAndget()を使用するstop()方法@Valueを呼び出すことにより、リスニングを停止カウンタをアトミックにインクリメントする方法
メッセージを1つだけ処理して処理したいですか？キューに100個のメッセージがある場合はどうなりますか？ –
@DarshanMehtaはいキューに100個のメッセージがあっても、単一のメッセージを処理して終了したいと思います。 – ManseUK
あなたはこれと同様のアプローチを使用することができます：https://stackoverflow.com/questions/41035454/how-to-stop-consuming-messages-with-rabbitlistener。 「AtomicInteger」を追加し、カウントが1に達すると消費を停止する可能性がありますか？ ackに関しては、 'listener'メソッドが正常に終了すると、Springはackを送信します。あなたが 'stop（）'を呼び出すと、それは肯定的ではないので、他のユーザがメッセージを利用できるようになります。 –