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.
This commit is contained in:
parent
ff53ca76b8
commit
9b149917a6
2 changed files with 3 additions and 1 deletions
2
changelogs/fragments/lookup_rabbitmq-is_closing-bug.yml
Normal file
2
changelogs/fragments/lookup_rabbitmq-is_closing-bug.yml
Normal file
|
@ -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:
|
else:
|
||||||
break
|
break
|
||||||
|
|
||||||
if connection.is_closing or connection.is_closed:
|
if connection.is_closed:
|
||||||
return [ret]
|
return [ret]
|
||||||
else:
|
else:
|
||||||
try:
|
try:
|
||||||
|
|
Loading…
Reference in a new issue