0

我正在使用 Symfony 2 和 videlalvaro/RabbitMqBundle 将消息推送到 Symfony 中的队列发布事件触发。

队列本身一切正常,消息在队列中看起来很完美。

我知道不可能在 AMQP 规范中更改消息的内容,但是是否可以添加或更改消息,如果是这样,有人知道这是如何完成的吗?

本质上,我正在尝试优雅地实现“最大重试次数”概念。以前,我已经“确认”了该消息并将相同的消息排入同一队列,只是现在增加了“尝试次数”字段。这很好,它有效,但感觉很混乱,这就是激发这个问题的原因。

TL;DR 有什么方法可以在重新排队之前更新消息,并且标头是最好的方法吗?

非常感谢您!

4

0 回答 0