Spring JMS listener acknowledging even when exception

Question

I am using JMS to send/receive messages to my SQS queue, however i am unable to redeliver the message when there is an exception even while using client_acknowledge. How to achieve this? I tried a simple test,

@JmsListener(destination = "test-normalqueue")
public void receiveNormalQueue(String message)
{

    try {
        logger.info("message received in normal queue: " + message);
        throw new NullPointerException();

    } catch (Exception e) {

        logger.error(LoggingUtil.getStackTrace(e));;
    }

}

Even after exception message doesnt come back to queue.

@Bean
public DefaultJmsListenerContainerFactory jmsListenerContainerFactory() {
    DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();
    factory.setConnectionFactory(getSQSConnectionFactory());
    factory.setConcurrency("1-2");
    factory.setSessionAcknowledgeMode(Session.CLIENT_ACKNOWLEDGE);
    return factory;
}

Answer 1

You have to use transactions with the DMLC.

Use Session.AUTO_ACKNOWLEDGE and setSessionTransacted(true).

If the listener exits normally, the message is removed. If the listener throws an exception, the message will be rolled-back onto the queue.

You can also use client mode with transactions, but you have to acknowledge successful messages yourself.

You don't have to use transactions with a SimpleMessageListenerContainer but you still have to throw an exception to get the message requeued.