diff options
author | Ask Solem <ask@celeryproject.org> | 2015-12-12 17:52:10 -0800 |
---|---|---|
committer | Ask Solem <ask@celeryproject.org> | 2015-12-12 17:52:10 -0800 |
commit | 91dd48d018c9a3e32a5262bab845c9f7f53ca864 (patch) | |
tree | 37269ab8f9fdd185dff3d076b3ccd8419c6f947d | |
parent | 325af35bca06acd271d01f92afffb25e947a9964 (diff) | |
download | kombu-91dd48d018c9a3e32a5262bab845c9f7f53ca864.tar.gz |
pyamqp: connection can be None in _collect. Closes #2960
-rw-r--r-- | kombu/transport/pyamqp.py | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/kombu/transport/pyamqp.py b/kombu/transport/pyamqp.py index b96837c2..f45e39ed 100644 --- 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.""" |