4

I'm wondering is it possible to set the max number of messages in the queue?

Let's say I want to have no more than 100 msgs in queue Foo, is it possible to do?

4

2 に答える 2

0

こうやって幸せになろう!

import pika


QUEUE_SIZE = 5

connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()

channel.queue_declare(
    queue='ids_queue',
    arguments={'x-max-length': QUEUE_SIZE}
)

ここの引数では、キューのキュー オーバーフロー動作も追跡する必要があります。

于 2020-06-26T13:05:51.933 に答える