From 8da6085df0774d0fa6e0fb17b7a8ce516ec4162e Mon Sep 17 00:00:00 2001 From: Zoe Roux Date: Tue, 9 Apr 2024 00:22:45 +0200 Subject: [PATCH] Process 20 messages at the same time --- scanner/scanner/subscriber.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/scanner/scanner/subscriber.py b/scanner/scanner/subscriber.py index 55ef3ae4..eaca56fe 100644 --- a/scanner/scanner/subscriber.py +++ b/scanner/scanner/subscriber.py @@ -49,4 +49,7 @@ class Subscriber: else: await message.nack(requeue=False) - await self._queue.consume(on_message, no_ack=True) + # Allow up to 20 scan requests to run in parallel on the same listener. + # Since most work is calling API not doing that is a waste. + await self._channel.set_qos(prefetch_count=20) + await self._queue.consume(on_message)