Use ensure_connection to allow broker failover

celery · Apr 26, 2017 · 816e3dc · 816e3dc · gabrielmartin · Oct 17, 2017
1 parent 259ac2e
commit 816e3dc
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/kombu/connection.py b/kombu/connection.py
@@ -816,7 +816,7 @@ def default_channel(self):
             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