What is the best strategy to handle exception in spring amqp SimpleMessageListenerContainer

Question

I have two confusions.

1.If RuntimeException thrown from message listener, does SimpleMessageListenrContainer stop? 2.If SimpleMessageListenerContainer not stop, what is behavior about the auto acknowledgement?

Currently, I want that if the message listener handle message failed, i just log the error and don't stop the container meanwhile notify the broker have received message.

Now I just catch the throwable in message listener method, is it the right way?

Answer 1

No, the container won't stop.

If the listener throws an exception, the message is rejected (and requeued by default). You can change the default behavior to discard the message by setting defaultRequeueRejected to false (it's true by default). Or throw an AmqpRejectAndDontRequeueException which instructs the container to reject (and not requeue) the message - the ack is sent as if the listener had thrown no exception.

When a message is rejected without requeuing, it is either discarded or sent to the dead letter exchange, if the queue is so configured.