lookup_rabbitmq pika > 1.0.0 is_closing bug fix (ansible#61959)

* In pika v1.0.0 BlockingChannel.is_closing was removed. Updating plugin accordingly. Ref: pika/pika#1034 * Adding change fragment for is_closing bug. * Updated change fragment description.
anas-shami · Sep 23, 2019 · d4c6de6 · d4c6de6
1 parent f493397
commit d4c6de6
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 1 deletion.
diff --git a/changelogs/fragments/lookup_rabbitmq-is_closing-bug.yml b/changelogs/fragments/lookup_rabbitmq-is_closing-bug.yml
@@ -0,0 +1,2 @@
+bugfixes:
+  - rabbitmq lookup plugin - Fix for rabbitmq lookups failing when using pika v1.0.0 and newer.
diff --git a/lib/ansible/plugins/lookup/rabbitmq.py b/lib/ansible/plugins/lookup/rabbitmq.py
@@ -180,7 +180,7 @@ def run(self, terms, variables=None, url=None, queue=None, count=None):
             else:
                 break
 
-        if connection.is_closing or connection.is_closed:
+        if connection.is_closed:
             return [ret]
         else:
             try: