From 6892ff871b1a154bbe669bf5cb10eab638fb181b Mon Sep 17 00:00:00 2001
From: Joshua McKenty <joshua.mckenty@nasa.gov>
Date: Fri, 16 Jul 2010 14:02:37 -0700
Subject: Ack messages during call so rabbit leaks less.

---
 nova/rpc.py | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/nova/rpc.py b/nova/rpc.py
index 72a84b7f7..99e820ff3 100644
--- a/nova/rpc.py
+++ b/nova/rpc.py
@@ -197,7 +197,10 @@ def call(topic, msg):
     conn = Connection.instance()
     d = defer.Deferred()
     consumer = DirectConsumer(connection=conn, msg_id=msg_id)
-    consumer.register_callback(lambda data, message: d.callback(data))
+    def deferred_receive(data, message):
+        message.ack()
+        d.callback(data)
+    consumer.register_callback(deferred_receive)
     injected = consumer.attach_to_tornado()
 
     # clean up after the injected listened and return x
-- 
cgit