Replace hardcoded "nova" with FLAGS.control_exchange.

This commit is contained in:
Ewan Mellor
2010-07-26 17:57:31 +00:00
committed by Tarmac

View File

@@ -243,7 +243,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)