更新 rabbitmq 中消息的有效负载

update payload of message in rabbitmq

如果可能需要帮助,我尝试更改 rabbitMQ 队列中的消息,但直到现在我还没有找到任何方法。

有什么方法可以实现吗?像一个插件或在 RabbitMQ Http 接口中?

示例:更改此消息的有效负载:

有关信息,我使用 spring 启动程序和 Amqp 启动程序来建立连接,有什么方法可以获取和更新类似此消息的特定消息吗?

提前,谢谢。

该请求在 Messaging 中根本没有意义。

消息中间件没有责任操纵 body 消息。在大多数情况下,它确实是明智的 application-based 信息,甚至可以得到保护。

另一方面,消息是 不可变的,因此对它的任何修改都会产生一条新消息。而且由于我们无法修改队列中的消息,因此实际上没有任何钩子可以帮助您。

我认为你需要重新考虑你对这个主题的看法并忍受你不能修改消息的事实。

但同时您可以使用原始消息,构建一个新消息作为其副本并修改正文并将其发送回队列。这就是您可以在应用程序中使用适当的消费者和生产者 API 执行的操作。