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