Recent commit broke Connection URL parsingv2.2.3

2 files changed, 3 insertions, 2 deletions

diff --git a/kombu/common.py b/kombu/common.py
index 42bf0a67..1aaf17bf 100644
--- a/kombu/common.py
+++ b/kombu/common.py
@@ -170,7 +170,8 @@ def collect_replies(conn, channel, queue, *args, **kwargs):
     no_ack = kwargs.setdefault('no_ack', True)
     received = False
     try:
-        for body, message in itermessages(conn, channel, queue, *args, **kwargs):
+        for body, message in itermessages(conn, channel, queue,
+                                          *args, **kwargs):
             if not no_ack:
                 message.ack()
             received = True
diff --git a/kombu/connection.py b/kombu/connection.py
index ff049c81..5c272ddf 100644
--- a/kombu/connection.py
+++ b/kombu/connection.py
@@ -107,7 +107,7 @@ class Connection(object):
                 params['transport'], params['hostname'] = hostname.split('+')
                 self.uri_prefix = params['transport']
             else:
-                if transport and transport not in URI_PASSTHROUGH:
+                if transport not in URI_PASSTHROUGH:
                     params.update(parse_url(hostname))
         self._init_params(**params)