pyamqp: connection can be None in _collect. Closes #2960

2015-12-12 17:52:10 -08:00 · 2015-12-12 17:52:10 -08:00 · 91dd48d018
parent 325af35bca
commit 91dd48d018
1 changed files with 2 additions and 1 deletions
--- a/kombu/transport/pyamqp.py
+++ b/kombu/transport/pyamqp.py
@ -98,7 +98,8 @@ class Transport(base.Transport):
        return connection.drain_events(**kwargs)

    def _collect(self, connection):
-        connection.collect()
+        if connection is not None:
+            connection.collect()

    def establish_connection(self):
        """Establish connection to the AMQP broker."""