diff options
| author | termie <github@anarkystic.com> | 2011-05-25 15:42:24 -0700 |
|---|---|---|
| committer | termie <github@anarkystic.com> | 2011-05-25 15:42:24 -0700 |
| commit | e3a88390fd62308cde3d4c597d653c8dc245bed4 (patch) | |
| tree | be8cee89835272775bd97607ddb8352e8eafb82a | |
| parent | 64b13a2aad676d2310947e3bf8b9e3dde6b763e7 (diff) | |
don't need to use a separate connection
| -rw-r--r-- | nova/rpc.py | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/nova/rpc.py b/nova/rpc.py index e1f594a99..a212383fd 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() |