Merge "AMQP Channel have to be set espacially to 'watcher'"

2015-11-27 15:42:12 +00:00
parent 5f8a601c63 aa1b1da759
commit 9d153e13a3
1 changed files with 1 additions and 0 deletions
--- a/watcher/decision_engine/rpcapi.py
+++ b/watcher/decision_engine/rpcapi.py
@@ -58,6 +58,7 @@ class DecisionEngineAPI(MessagingCore):

        transport = om.get_transport(CONF, TransportUrlBuilder().url)
        target = om.Target(
+            exchange='watcher',
            topic=CONF.watcher_decision_engine.topic_control,
            version=MessagingCore.API_VERSION)