lookup_rabbitmq pika > 1.0.0 is_closing bug fix (#61959)

* In pika v1.0.0 BlockingChannel.is_closing was removed.  Updating
plugin accordingly.

Ref: https://github.com/pika/pika/pull/1034

* Adding change fragment for is_closing bug.

* Updated change fragment description.

(cherry picked from commit 9b149917a6)
pull/62378/head
John Imison 5 years ago committed by Toshio Kuratomi
parent 0666a2987d
commit 87c9514565

@ -0,0 +1,2 @@
bugfixes:
- rabbitmq lookup plugin - Fix for rabbitmq lookups failing when using pika v1.0.0 and newer.

@ -180,7 +180,7 @@ class LookupModule(LookupBase):
else:
break
if connection.is_closing or connection.is_closed:
if connection.is_closed:
return [ret]
else:
try:

Loading…
Cancel
Save