set prefetch_size to 0 as its not supported by rabbitmq

hpi-schul-cloud · Sep 16, 2024 · a50f9ad · a50f9ad
1 parent d610e07
commit a50f9ad
Showing 1 changed file with 2 additions and 1 deletion.
diff --git 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)