diff options
| author | Ask Solem <ask@celeryproject.org> | 2014-10-24 15:55:00 +0100 |
|---|---|---|
| committer | Ask Solem <ask@celeryproject.org> | 2014-10-24 15:55:00 +0100 |
| commit | 10fc219aeefe90e4cbc7326dfd69842a3884d088 (patch) | |
| tree | 7c12ad8fb534b629746e59928a576bfb69dae834 /kombu/transport/pyamqp.py | |
| parent | 6e84281d2b598af7bfed98a95a9abfd3284822eb (diff) | |
| download | kombu-10fc219aeefe90e4cbc7326dfd69842a3884d088.tar.gz | |
Implements collect for pyamqp transport. Closes celery/celery#2312
Diffstat (limited to 'kombu/transport/pyamqp.py')
| -rw-r--r-- | kombu/transport/pyamqp.py | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/kombu/transport/pyamqp.py b/kombu/transport/pyamqp.py index 71f462fe..e32380e9 100644 --- a/kombu/transport/pyamqp.py +++ b/kombu/transport/pyamqp.py @@ -93,6 +93,9 @@ class Transport(base.Transport): def drain_events(self, connection, **kwargs): return connection.drain_events(**kwargs) + def _collect(self, connection): + connection.collect() + def establish_connection(self): """Establish connection to the AMQP broker.""" conninfo = self.client |