是否可以将pika
( python-pika
) 中的队列声明为循环队列?如果是,如何?
我的意思是循环队列(或环)是一个队列,当一条消息被选中时,它将被重新插入到队列的末尾,而不是从队列中删除。例如,如果队列包含:msg_3
, msg_2
, msg_1
, 那么在一个消费者 get 之后msg_1
, 后者将被插入到最后, 所以队列将是: msg_1
, msg_3
, msg_2
(而不是msg_3
, msg_2
)
编辑:正如IMSoP所建议的,我可以让消费者重新发布每条消费的消息(例如,在回调函数的末尾)。