Use ensure_connection to allow broker failover

2017-04-19 22:00:36 +03:00 · 2017-04-19 22:00:36 +03:00 · 816e3dcf34
parent 259ac2e2bf
commit 816e3dcf34
1 changed files with 1 additions and 1 deletions
--- a/kombu/connection.py
+++ b/kombu/connection.py
@ -816,7 +816,7 @@ class Connection(object):
            require a channel.
        """
        # make sure we're still connected, and if not refresh.
-        self.connection
+        self.ensure_connection()
        if self._default_channel is None:
            self._default_channel = self.channel()
        return self._default_channel