channel.forget_consumer: handle KeyError.

834eb793 · Sam Rushing · 1744b403 · 834eb793
Commit 834eb793 authored May 01, 2015 by Sam Rushing
Show whitespace changes
Inline Side-by-side

Showing with 4 additions and 1 deletion

coro/amqp/amqp.py coro/amqp/amqp.py +4 -1

No files found.
--- a/coro/amqp/amqp.py
+++ b/coro/amqp/amqp.py
@@ -463,7 +463,10 @@ class channel:
        self.consumers[con.tag] = con
    def forget_consumer (self, tag):
+        try:
            del self.consumers[tag]
+        except KeyError:
+            pass
    def notify_consumers_of_close (self):
        for _, con in self.consumers.iteritems():