diff --git a/coolamqp/attaches/consumer.py b/coolamqp/attaches/consumer.py index d08bc496346ac691c89a2d17f3f7fecd4d52f70d..9a921b3f5f8b7b47d9f5d1a6ebd4594d4a3e63d5 100644 --- a/coolamqp/attaches/consumer.py +++ b/coolamqp/attaches/consumer.py @@ -310,7 +310,7 @@ class Consumer(Channeler): if self.future_to_notify_on_dead: # notify it was cancelled logger.info('Consumer successfully cancelled') self.future_to_notify_on_dead.set_result(None) - + self.future_to_notify_on_dead = None if should_retry: if old_con.state == ST_ONLINE: logger.info('Retrying with %s', self.queue.name)