diff --git a/watcher/decision_engine/rpcapi.py b/watcher/decision_engine/rpcapi.py
index 5f79c34ab..889aa1959 100644
--- 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)