在RabbitMQ中删除或更新消息

问题描述 投票:0回答:1

我已经进行了一些研究,但无法找到任何解决方案来删除或修改队列中已经存在的消息。(RabbitMQ)。

[用例:我正在尝试通过RabbitMQ中的延迟消息功能(headers.put(“ x-delay”,5000))发送通知(让我们在30分钟后说)。我想发送一个事件,该事件可以删除/修改消息的内容。 RabbitMQ有什么方法可以做到这一点。另一种方法是使用数据库和调度程序,如果不可能的话,我将实现它们。在此先感谢

java rabbitmq spring-rabbitmq
1个回答
0
投票

不确定您的情况。假设您要删除或修改RabbitMQ上的现有消息。

如果您有FIFO情况,可以检查此How to selectively delete messages from an AMQP (RabbitMQ) queue?

我的建议是,您可以使用插入和删除方法,将具有唯一ID的已修改消息推送到db / cache和您的消息队列。并且无论何时进行修改或删除,都应从数据库/缓存中将其删除。当使用者使用该消息时,它可以忽略是否在db / cache中不存在。

© www.soinside.com 2019 - 2024. All rights reserved.