diff --git a/antivirus_service/consumer.py b/antivirus_service/consumer.py index 52745f2..1602d14 100644 --- a/antivirus_service/consumer.py +++ b/antivirus_service/consumer.py @@ -36,6 +36,7 @@ def run(self): self.connection = pika.BlockingConnection(params) channel = self.connection.channel() + channel.basic_qos(1, 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)