发送到RabbitMq后如何获取messageId？

Question

当我发送到 Rabbit Mq Queue 时，我需要一些 messageId 类的东西，就像我在使用 jms 发送到 IBM MQ 时会得到的一样。我正在使用 spring MQ amqp starter 依赖项和 Spring Boot。配置仅在 application.yml（属性文件）中完成。我正在使用 Rabbit 模板发送。

rabbitMqTemplate.convertAndSend(EMPTY_STRING,queueName, message, messagePostProcessor);

我试过messagePostProcessor。任何帮助表示赞赏。我查看了以下内容。但不明白如何实施。是否需要特殊配置（connectionfactory/container）？

https://www.rabbitmq.com/confirms.html

Answer 1

与 JMS 不同，rabbit 客户端不分配消息 ID。

但是，您可以配置 RabbitTemplate 的 MessageConverter 来创建一个 ID，然后您可以使用 post 处理器检索它。

参见AbstractMessageConverter...

/**
 * Flag to indicate that new messages should have unique identifiers added to their properties before sending.
 * Default false.
 * @param createMessageIds the flag value to set
 */
public void setCreateMessageIds(boolean createMessageIds) {
    this.createMessageIds = createMessageIds;
}

有关消息确认，请参阅 reference manual。但这与消息 id 属性.

无关

发送到RabbitMq后如何获取messageId？

How can I get messageId after sending to RabbitMq?

amqp

rabbitmq

spring-amqp

spring-boot