pika
( python-pika
)内のキューを循環キューとして宣言することは可能ですか? はいの場合、どのように?
つまり、循環キュー (またはリング) は、メッセージが選択されたときにキューから削除されるのではなく、キューの最後に再挿入されるキューです。たとえば、キューにmsg_3
, msg_2
,が含まれている場合msg_1
、コンシューマー get の後msg_1
、後者が最後に挿入されるため、キューはmsg_1
, msg_3
, msg_2
( ではなくmsg_3
)msg_2
になります。
編集: IMSoPで提案されているように、コンシューマーがすべての消費されたメッセージを再発行するようにすることができます (たとえば、コールバック関数の最後で)。