Fix custom transport overriding

celery · Apr 17, 2015 · aafea84 · aafea84
1 parent c3a6a6b
commit aafea84
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/kombu/connection.py b/kombu/connection.py
@@ -162,12 +162,12 @@ def __init__(self, hostname='localhost', userid=None,
                 transport = self.uri_prefix = params['transport']
             else:
                 transport = transport or urlparse(hostname).scheme
-                if get_transport_cls(transport).can_parse_url:
-                    # set the transport so that the default is not used.
-                    params['transport'] = transport
-                else:
+                if not get_transport_cls(transport).can_parse_url:
                     # we must parse the URL
                     params.update(parse_url(hostname))
+
+                params['transport'] = transport
+
         self._init_params(**params)
 
         # fallback hosts