Sign Up
Log In
Log In
or
Sign Up
Places
All Projects
Status Monitor
Collapse sidebar
Cloud:OpenStack:Newton
python-kombu
0001-Pass-connection-options-from-broker_option...
Overview
Repositories
Revisions
Requests
Users
Attributes
Meta
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
Locations
Projects
Search
Status Monitor
Help
OpenBuildService.org
Documentation
API Documentation
Code of Conduct
Contact
Support
@OBShq
Terms
openSUSE Build Service is sponsored by
The Open Build Service is an
openSUSE project
.
Sign Up
Log In
Places
Places
All Projects
Status Monitor