springboot activemq关闭持久化不起作用

springboot activemq关闭持久化不起作用,第1张

springboot activemq关闭持久化不起作用

需要写jmsTemplate.setExplicitQosEnabled(true);

    @Bean
    public JmsTemplate jmsTemplate(ActiveMQConnectionFactory connectionFactory) {
        JmsTemplate jmsTemplate = new JmsTemplate();
        jmsTemplate.setConnectionFactory(connectionFactory);
        //deliveryMode, priority, timeToLive 的开关,要生效,必须配置为true,默认false
        jmsTemplate.setExplicitQosEnabled(true);
        // 持久化消息
        jmsTemplate.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
        // 是否开启事务
        jmsTemplate.setSessionTransacted(false);
        // 消费者receive消息后必须手动的调用acknowledge()方法进行签收
        jmsTemplate.setSessionAcknowledgeMode(Session.CLIENT_ACKNOWLEDGE);
        return jmsTemplate;
    }

欢迎分享,转载请注明来源:内存溢出

原文地址: http://outofmemory.cn/zaji/5653303.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2022-12-16
下一篇 2022-12-16

发表评论

登录后才能评论

评论列表(0条)

保存