diff options
| -rw-r--r-- | kombu/connection.py | 3 |
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') |