Use the Connection.qos_semantics_matches_spec property instead

pyzen · Apr 15, 2014 · abf1ff9 · abf1ff9
1 parent 7289933
commit abf1ff9
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/celery/worker/consumer.py b/celery/worker/consumer.py
@@ -596,9 +596,7 @@ def start(self, c):
         # - RabbitMQ 3.3 completely redefines how basic_qos works..
         # This will detect if the new qos smenatics is in effect,
         # and if so make sure the 'apply_global' flag is set on qos updates.
-        qos_global = not (
-            c.connection.transport.qos_semantics_matches_spec(
-                c.connection.connection))
+        qos_global = not c.connection.qos_semantics_matches_spec
 
         # set initial prefetch count
         c.connection.default_channel.basic_qos(