Handle exception on Ctrl-C

Signed-off-by: Zane Bitter <zbitter@redhat.com>
2012-04-17 17:38:48 +02:00 · 2012-04-17 17:38:48 +02:00 · f94547743e
commit f94547743e
parent 27832d617e
1 changed files with 5 additions and 1 deletions
--- a/heat/rpc/amqp.py
+++ b/heat/rpc/amqp.py
@ -60,7 +60,11 @@ class Pool(pools.Pool):

    def empty(self):
        while self.free_items:
-            self.get().close()
+            item = self.get()
+            try:
+                item.close()
+            except Exception:
+                pass


 class ConnectionContext(rpc_common.Connection):