Skip to content

Commit

Permalink
BC-8052 hardcode prefetch size and count to 1 (#61)
Browse files Browse the repository at this point in the history
to allow effective autoscaling
  • Loading branch information
Loki-Afro authored Sep 10, 2024
1 parent da816f1 commit d610e07
Showing 1 changed file with 1 addition and 0 deletions.
1 change: 1 addition & 0 deletions antivirus_service/consumer.py
Original file line number Diff line number Diff line change
Expand Up @@ -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)
Expand Down

0 comments on commit d610e07

Please sign in to comment.