From d0be426d4e7bbfb1ecb3f078c71c1e176da441a5 Mon Sep 17 00:00:00 2001
From: Chris Behrens <cbehrens@codestud.com>
Date: Wed, 25 May 2011 15:42:24 -0700
Subject: convert fanout_cast to ConnectionPool

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

diff --git a/nova/rpc.py b/nova/rpc.py
index db5aec826..fdb228695 100644
--- a/nova/rpc.py
+++ b/nova/rpc.py
@@ -526,10 +526,11 @@ def fanout_cast(context, topic, msg):
     """Sends a message on a fanout exchange without waiting for a response."""
     LOG.debug(_('Making asynchronous fanout cast...'))
     _pack_context(msg, context)
-    conn = Connection.instance()
+    conn = ConnectionPool.get()
     publisher = FanoutPublisher(topic, connection=conn)
     publisher.send(msg)
     publisher.close()
+    ConnectionPool.put(conn)
 
 
 def generic_response(message_data, message):
-- 
cgit