From 2f5ff502f80f28ccdb715bd0056111d66c06e8de Mon Sep 17 00:00:00 2001 From: Phillip Date: Mon, 16 Sep 2024 10:32:39 +0200 Subject: [PATCH] set prefetch_size to 0 as its not supported by rabbitmq (#62) --- 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)