You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
I first set prefetch_count to 2, and then I bind the queue to a consumer, and I do get 2 pieces of data at the same time, but then I reset prefetch_count, and it doesn't work, I don't get 4 pieces of data at once.
awaitchannel.set_qos(prefetch_count=2, global_=False)
queue=awaitchannel.get_queue(queue_name)
consume_tag=awaitqueue.consume(on_message)
awaitasyncio.sleep(3)
# reset after 3s or more timeawaitchannel.set_qos(prefetch_count=4 , global_=False)
The text was updated successfully, but these errors were encountered:
I first set prefetch_count to 2, and then I bind the queue to a consumer, and I do get 2 pieces of data at the same time, but then I reset prefetch_count, and it doesn't work, I don't get 4 pieces of data at once.
The text was updated successfully, but these errors were encountered: