diff --git a/changelogs/fragments/lookup_rabbitmq-is_closing-bug.yml b/changelogs/fragments/lookup_rabbitmq-is_closing-bug.yml new file mode 100644 index 00000000000000..57eac0175fe651 --- /dev/null +++ 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 index 2596359c9b3eaa..7c2745f41dd18b 100644 --- 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: