java – Spring JMS监听器即使在异常时也会确认

前端之家收集整理的这篇文章主要介绍了java – Spring JMS监听器即使在异常时也会确认前端之家小编觉得挺不错的,现在分享给大家,也给大家做个参考。

我正在使用JMS向我的SQS队列发送/接收消息,但是即使在使用client_acknowledge时出现异常,我也无法重新发送消息.怎么做到这一点?
我试过一个简单的测试,

@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));;
    }

}

即使异常消息没有回到队列.

@Bean
public DefaultJmsListenerContainerFactory jmsListenerContainerFactory() {
    DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();
    factory.setConnectionFactory(getSQSConnectionFactory());
    factory.setConcurrency("1-2");
    factory.setSessionAcknowledgeMode(Session.CLIENT_ACKNOWLEDGE);
    return factory;
}
最佳答案
您必须使用DMLC的交易.

使用Session.AUTO_ACKNOWLEDGE和setSessionTransacted(true).

如果侦听器正常退出,则会删除该消息.如果侦听器抛出异常,则消息将回滚到队列中.

您还可以将客户端模式与事务一起使用,但您必须自己确认成功的消息.

您不必使用SimpleMessageListenerContainer的事务,但仍需要抛出异常以使消息重新排队.

猜你在找的Spring相关文章