summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--kombu/connection.py3
1 files changed, 2 insertions, 1 deletions
diff --git a/kombu/connection.py b/kombu/connection.py
index f66bd1d7..1586f638 100644
--- a/kombu/connection.py
+++ b/kombu/connection.py
@@ -136,6 +136,7 @@ class Connection(object):
def _init_params(self, hostname, userid, password, virtual_host, port,
insist, ssl, transport, connect_timeout, login_method, heartbeat):
+ transport = transport or 'amqp'
if transport == 'amqp' and supports_librabbitmq():
transport = 'librabbitmq'
self.hostname = hostname
@@ -407,7 +408,7 @@ class Connection(object):
return self.__class__(**dict(self._info(), **kwargs))
def _info(self):
- transport_cls = self.transport_cls or 'amqp'
+ transport_cls = self.transport_cls
transport_cls = RESOLVE_ALIASES.get(transport_cls, transport_cls)
D = self.transport.default_connection_params
hostname = self.hostname or D.get('hostname')