diff options
| -rw-r--r-- | nova/rpc.py | 5 |
1 files changed, 4 insertions, 1 deletions
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 |