0

是否可以将pika( python-pika) 中的队列声明为循环队列?如果是,如何?

我的意思是循环队列(或环)是一个队列,当一条消息被选中时,它将被重新插入到队列的末尾,而不是从队列中删除。例如,如果队列包含:msg_3, msg_2, msg_1, 那么在一个消费者 get 之后msg_1, 后者将被插入到最后, 所以队列将是: msg_1, msg_3, msg_2(而不是msg_3, msg_2)

编辑:正如IMSoP所建议的,我可以让消费者重新发布每条消费的消息(例如,在回调函数的末尾)。

4

0 回答 0