加入收藏 | 设为首页 | 会员中心 | 我要投稿 李大同 (https://www.lidatong.com.cn/)- 科技、建站、经验、云计算、5G、大数据,站长网!
当前位置: 首页 > 大数据 > 正文

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

发布时间:2020-12-15 01:47:20 所属栏目:大数据 来源:网络整理
导读:我正在使用JMS向我的SQS队列发送/接收消息,但是即使在使用client_acknowledge时出现异常,我也无法重新发送消息.怎么做到这一点? 我试过一个简单的测试, @JmsListener(destination = "test-normalqueue")public void receiveNormalQueue(String message){ tr

我正在使用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的事务,但仍需要抛出异常以使消息重新排队.

(编辑:李大同)

【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容!

    推荐文章
      热点阅读