diff options
| author | Matus Valo <matusvalo@users.noreply.github.com> | 2020-05-25 00:06:38 +0200 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2020-05-25 00:06:38 +0200 |
| commit | 4644a5e9400beac6668f326c16078286f7d60b64 (patch) | |
| tree | 5c3247bfa4616a91ce2204dec0643f26cf40521d /kombu/common.py | |
| parent | 91d4ef0a1d1158d2b3b2801f0e27db0bb67a2521 (diff) | |
| download | kombu-4644a5e9400beac6668f326c16078286f7d60b64.tar.gz | |
Revert "Raise RecoverableConnectionError in maybe_declare with retry on and dropped connection" (#1195)
This reverts commit 90f51bcbbd32146998e7c7e4491150344343776b.
Diffstat (limited to 'kombu/common.py')
| -rw-r--r-- | kombu/common.py | 4 |
1 files changed, 0 insertions, 4 deletions
diff --git a/kombu/common.py b/kombu/common.py index 8c2c847d..30abe1c6 100644 --- a/kombu/common.py +++ b/kombu/common.py @@ -168,10 +168,6 @@ def _maybe_declare(entity, channel): def _imaybe_declare(entity, channel, **retry_policy): _ensure_channel_is_bound(entity, channel) - - if not channel.connection: - raise RecoverableConnectionError('channel disconnected') - return entity.channel.connection.client.ensure( entity, _maybe_declare, **retry_policy)(entity, channel) |