【问题标题】:How can I get messageId after sending to RabbitMq?发送到 RabbitMq 后如何获取 messageId?
【发布时间】:2018-03-28 13:43:52
【问题描述】:

当我发送到 Rabbit Mq 队列时,我想要一些 messageId 类型的东西,就像使用 jms 发送到 IBM MQ 时一样。我正在使用 Spring MQ amqp 启动器依赖项和 Spring Boot。配置仅在 application.yml(属性文件)中完成。我正在使用 Rabbit 模板发送。

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

我已经尝试过 messagePostProcessor。任何帮助表示赞赏。我查看了以下内容。但不明白如何实现。是否需要特殊配置(connectionfactory/container)?

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

【问题讨论】:

    标签: spring-boot rabbitmq amqp spring-amqp


    【解决方案1】:

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

    但是,您可以配置 RabbitTemplateMessageConverter 来创建一个 id,然后您可以使用后处理器检索它。

    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 属性无关。

    【讨论】:

    猜你喜欢
    • 1970-01-01
    • 2017-07-06
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 2020-05-19
    • 1970-01-01
    • 1970-01-01
    相关资源
    最近更新 更多