如何使用spring-rabbitmq将消息标记为持久？

Posted 2023-02-16

【中文标题】如何使用spring-rabbitmq将消息标记为持久？

【英文标题】：how to mark a message as persistent using spring-rabbitmq?

【发布时间】：2016-11-07 11:06:18

【问题描述】：

这就是我创建交换并将队列绑定到它的方式

<rabbit:topic-exchange id="dataExchange" name="MQ-EXCHANGE" durable="true">
        <rabbit:bindings>
            <rabbit:binding queue="COMM_QUEUE" pattern="queue.*" />
        </rabbit:bindings>
</rabbit:topic-exchange>

我在 Internet 上阅读了很多帖子，其中写道，如果要在 rabbitmq 或队列崩溃的情况下保护消息，还需要将消息标记为持久。但我不知道如何将我的消息标记为持久。

这就是我将消息发布到队列的方式

    @Autowired
    private RabbitTemplate template;

    @Override
    public void produceMessage(Object message, String routingKey) 
        template.convertAndSend(routingKey, message);  
    

我寻找不同的 API 方法来了解这一点，并尝试寻找我可以在 XML 中配置但找不到方法的任何特定属性。有什么指导吗？

【参考方案1】：

默认交付模式（MessageProperties）是PERSISTENT。见here。

要使其非持久化，您需要使用带有MessagePostProcessor 的convertAndSend(...) 方法来设置deliveryMode 属性。