Rooba
/
kombu
mirror of https://github.com/celery/kombu.git
1
1
Fork 0
Code Issues Packages Projects Releases Wiki Activity

2to3 says we should use a for loop here

This commit is contained in:
Ask Solem 2010-12-02 15:24:35 +01:00
parent 97ac8b077c
commit eb7748d27b
2 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
examples/complete_send.py
View File

@ -2,7 +2,7 @@
Example producer that sends a single message and exits. Example producer that sends a single message and exits.
You can use `demo_receive.py` to receive the message sent. You can use `complete_receive.py` to receive the message sent.
""" """

3
kombu/transport/virtual/__init__.py
View File

@ -437,7 +437,8 @@ class Channel(AbstractChannel):
"""Close channel, cancel all consumers, and requeue unacked """Close channel, cancel all consumers, and requeue unacked
messages.""" messages."""
self.closed = True self.closed = True
map(self.basic_cancel, list(self._consumers)) for consumer in list(self._consumers):
self.basic_cancel(consumer)
self.qos.restore_unacked_once() self.qos.restore_unacked_once()
self.connection.close_channel(self) self.connection.close_channel(self)
self._cycle = None self._cycle = None