kombu.mixins: Fixes typo

2011-11-28 15:37:25 +00:00 · 2011-11-28 15:37:25 +00:00 · 246e42efed
parent da7d21af6f
commit 246e42efed
1 changed files with 1 additions and 1 deletions
--- a/kombu/mixins.py
+++ b/kombu/mixins.py
@ -219,7 +219,7 @@ class ConsumerMixin(LogMixin):
            with self._consume_from(*self.get_consumers(cls, channel)) as c:
                yield conn, channel, c
            self.debug("Consumers cancelled")
-            self.on_consume_end(connection, channel)
+            self.on_consume_end(conn, channel)
        self.debug("Connection closed")

    @contextmanager