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)