From 93cf5aad54aad6f3e8efbf74bf548898a21107c1 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 | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/antivirus_service/consumer.py b/antivirus_service/consumer.py index 1602d14..fe6d74b 100644 --- a/antivirus_service/consumer.py +++ b/antivirus_service/consumer.py @@ -36,7 +36,7 @@ def run(self): self.connection = pika.BlockingConnection(params) channel = self.connection.channel() - 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)