diff options
| -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 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() |