summaryrefslogtreecommitdiff
path: root/nova/rpc.py
diff options
context:
space:
mode:
authortermie <github@anarkystic.com>2011-05-25 15:42:24 -0700
committertermie <github@anarkystic.com>2011-05-25 15:42:24 -0700
commite3a88390fd62308cde3d4c597d653c8dc245bed4 (patch)
treebe8cee89835272775bd97607ddb8352e8eafb82a /nova/rpc.py
parent64b13a2aad676d2310947e3bf8b9e3dde6b763e7 (diff)
downloadnova-e3a88390fd62308cde3d4c597d653c8dc245bed4.tar.gz
don't need to use a separate connection
Diffstat (limited to 'nova/rpc.py')
-rw-r--r--nova/rpc.py3
1 files changed, 1 insertions, 2 deletions
diff --git a/nova/rpc.py b/nova/rpc.py
index e1f594a99a..a212383fde 100644
--- a/nova/rpc.py
+++ b/nova/rpc.py
@@ -481,8 +481,7 @@ def multicall(context, topic, msg):
wait_msg = MulticallWaiter(consumer)
consumer.register_callback(wait_msg)
- pub_conn = ConnectionPool.get()
- publisher = TopicPublisher(connection=pub_conn, topic=topic)
+ publisher = TopicPublisher(connection=con_conn, topic=topic)
publisher.send(msg)
publisher.close()