switch from global QoS to per-consumer for #1233 & quorum queue compa…

…tibility
MetPX · Sep 25, 2024 · b2f281a · b2f281a
1 parent d5584a5
commit b2f281a
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/sarracenia/moth/amqp.py b/sarracenia/moth/amqp.py
@@ -349,7 +349,8 @@ def getSetup(self) -> None:
                 #logger.info('getSetup connected to {}'.format(self.o['broker'].url.hostname) )
 
                 if self.o['prefetch'] != 0:
-                    self.channel.basic_qos(0, self.o['prefetch'], True)
+                    # using global False because RabbitMQ Quorum Queues don't support Global QoS, issue #1233
+                    self.channel.basic_qos(0, self.o['prefetch'], False)
 
                 #FIXME: test self.first_setup and props['reset']... delete queue...
                 broker_str = self.o['broker'].url.geturl().replace(