Replace hardcoded "nova" with FLAGS.control_exchange.

2010-07-25 17:40:41 +01:00
parent 0c57be0d93
commit cad5c82187
1 changed files with 1 additions and 1 deletions
--- a/nova/rpc.py
+++ b/nova/rpc.py
@@ -242,7 +242,7 @@ def send_message(topic, message, wait=True):
        consumer.register_callback(generic_response)

    publisher = messaging.Publisher(connection=Connection.instance(),
-                                    exchange="nova",
+                                    exchange=FLAGS.control_exchange,
                                    exchange_type="topic",
                                    routing_key=topic)
    publisher.send(message)