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 /kombu/transport/pyamqp.py | |
| parent | 325af35bca06acd271d01f92afffb25e947a9964 (diff) | |
| download | kombu-91dd48d018c9a3e32a5262bab845c9f7f53ca864.tar.gz | |
pyamqp: connection can be None in _collect. Closes #2960
Diffstat (limited to 'kombu/transport/pyamqp.py')
| -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.""" |