MessageListenerが例外をスローすると、RabbitMQリスナーはリッスンメッセージを停止します

Question

私はRabbitMQでメッセージを処理するためにSpring AMQPを使用しています。

問題は次のとおりです。
1. RabbitMQ内で準備状態のメッセージが3つあります。
2.最初に1つがMessageListenerによって取得され、処理が開始されます。 （例）例外がスローされて終了する
3.この場合、コンテナを再起動するまで、残りの2つのメッセージは処理されません。また、最初のメッセージは未確認の状態のままです。

これは予期された動作ですか？そうでない場合は、最初の処理に失敗しても、他の2つのメッセージが処理されることを確認する方法はありますか？

MQのconfiguraion：

<rabbit:connection-factory id="connectionFactory" host="localhost" username="guest" password="guest" /> 

<rabbit:admin connection-factory="connectionFactory" /> 

<rabbit:listener-container 
    connection-factory="connectionFactory" 
    concurrency="1" 
    acknowledge="auto"> 
    <rabbit:listener queue-names="testQueue" ref="myProcessorListener " /> 
</rabbit:listener-container> 

するMessageListenerクラス：

public class MyProcessorListener implements MessageListener{ 
.... 
    @Override 
public void onMessage(Message message) { 
try{ 
...Some logic... 

} catch (Exception e) { 
    throw new RuntimeException(e.getMessage(), e); 
} 

Answer 1

メッセージが何度も何度も再配信されています。それを拒否する（およびデッド・レター・キューへの廃棄またはルーティング）ためには、AmqpRejectAndDontRequeueExceptionを投げるか、コンテナのrequeue-rejectedプロパティをfalseに設定する必要があります。 Javaで設定する場合はdefaultRequeueRejectedです。

カスタムエラーハンドラを使用することもできます。

これはすべてexplained in the reference manualです。