From a50f9ad6e17b65c5a82cf56f6893faa2d0a7d675 Mon Sep 17 00:00:00 2001 From: Phillip Wirth Date: Mon, 16 Sep 2024 10:13:01 +0200 Subject: [PATCH] set prefetch_size to 0 as its not supported by rabbitmq --- antivirus_service/consumer.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/antivirus_service/consumer.py b/antivirus_service/consumer.py index 1602d14..81ade85 100644 --- a/antivirus_service/consumer.py +++ b/antivirus_service/consumer.py @@ -36,7 +36,8 @@ def run(self): self.connection = pika.BlockingConnection(params) channel = self.connection.channel() - channel.basic_qos(1, 1) + # channel.basic_qos(1, 1) + channel.basic_qos(0, 1) channel.queue_declare(self.amqp_queue, durable=True) channel.queue_bind(self.amqp_queue, self.exchange) channel.basic_consume(self.amqp_queue, self._callback)