File 0001-Pass-connection-options-from-broker_options-to-defau.patch of Package python-kombu
From 0f4da8d450d1a44558382c1858f025faea1b3fde Mon Sep 17 00:00:00 2001
From: Anthony Lukach <anthonylukach@gmail.com>
Date: Wed, 2 Aug 2017 03:06:47 -0600
Subject: [PATCH] Pass connection options from broker_options to
default_channel (#769)
* Pass connection options from broker_options to default_channel (fixes #765)
* Fixup
* Fixup
---
Changelog | 14 ++++++++++++++
kombu/connection.py | 14 +++++++++++++-
t/unit/test_connection.py | 26 ++++++++++++++++++++++++++
3 files changed, 53 insertions(+), 1 deletion(-)
Index: kombu-3.0.35/kombu/connection.py
===================================================================
--- kombu-3.0.35.orig/kombu/connection.py
+++ kombu-3.0.35/kombu/connection.py
@@ -753,8 +753,20 @@ class Connection(object):
is passed instead of a channel, to functions that require a channel.
"""
+ conn_opts = {}
+ transport_opts = self.transport_options
+ if transport_opts:
+ if 'max_retries' in transport_opts:
+ conn_opts['max_retries'] = transport_opts['max_retries']
+ if 'interval_start' in transport_opts:
+ conn_opts['interval_start'] = transport_opts['interval_start']
+ if 'interval_step' in transport_opts:
+ conn_opts['interval_step'] = transport_opts['interval_step']
+ if 'interval_max' in transport_opts:
+ conn_opts['interval_max'] = transport_opts['interval_max']
+
# make sure we're still connected, and if not refresh.
- self.ensure_connection()
+ self.ensure_connection(**conn_opts)
if self._default_channel is None:
self._default_channel = self.channel()
return self._default_channel