summaryrefslogtreecommitdiff
path: root/kombu/transport/librabbitmq.py
diff options
context:
space:
mode:
authorAsk Solem <ask@celeryproject.org>2013-06-25 13:08:24 +0100
committerAsk Solem <ask@celeryproject.org>2013-06-25 13:08:47 +0100
commit0acec63eaf6853a6f300481834d71ea0f7732e73 (patch)
tree22992f6c2dcd859c4c549419a8a62cc6bd52daee /kombu/transport/librabbitmq.py
parente8a33347697180b1bd5da850c4599aeb6dcf8422 (diff)
downloadkombu-0acec63eaf6853a6f300481834d71ea0f7732e73.tar.gz
pyamqp/librabbitmq: Transport options are now forwarded as kwargs to Connection. Closes #214.
Diffstat (limited to 'kombu/transport/librabbitmq.py')
-rw-r--r--kombu/transport/librabbitmq.py3
1 files changed, 2 insertions, 1 deletions
diff --git a/kombu/transport/librabbitmq.py b/kombu/transport/librabbitmq.py
index cc44db81..97e01b7b 100644
--- a/kombu/transport/librabbitmq.py
+++ b/kombu/transport/librabbitmq.py
@@ -112,7 +112,8 @@ class Transport(base.Transport):
login_method=conninfo.login_method,
insist=conninfo.insist,
ssl=conninfo.ssl,
- connect_timeout=conninfo.connect_timeout)
+ connect_timeout=conninfo.connect_timeout,
+ **conninfo.transport_options or {})
conn.client = self.client
self.client.drain_events = conn.drain_events
return conn