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