RabbitMQ请求队列功能



考虑到我有一个包含X条消息的大队列。每当创建一个带有requeue=True的nack时,它就会将该消息放在X消息之上,并将其重新交付给同一个消费者,从而造成瓶颈,不让消费者处理其他消息。

是否有一种方法可以将消息放在队列的尾部,将它们视为新消息,因此如果我有X个消息,我可以在队列消息之前先处理它们?

在这个问题中,如果有错误,我不想ACK消息,然后丢失它,我想跟踪unprocessed消息。

我意识到我可以创建另一个队列来保存未处理的消息,并让其他消息流动!

最新更新