diff options
| author | Matus Valo <matusvalo@users.noreply.github.com> | 2020-06-05 09:20:56 +0200 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2020-06-05 09:20:56 +0200 |
| commit | 16749626a4b206501ed46577646ad24695cf912d (patch) | |
| tree | 7dae7ad54b1b6c0cd63f6deaa901d57fb75f4532 /kombu | |
| parent | ce6d2016406cd65d3ceaf62d4753b5a1d59a9b67 (diff) | |
| download | kombu-16749626a4b206501ed46577646ad24695cf912d.tar.gz | |
default_channel should reconnect automatically (#1209)
Diffstat (limited to 'kombu')
| -rw-r--r-- | kombu/connection.py | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/kombu/connection.py b/kombu/connection.py index 65dcb52b..5a5af519 100644 --- a/kombu/connection.py +++ b/kombu/connection.py @@ -883,6 +883,8 @@ class Connection(object): a connection is passed instead of a channel, to functions that require a channel. """ + # make sure we're still connected, and if not refresh. + self.connect() if self._default_channel is None: self._default_channel = self.channel() return self._default_channel |