commit 892944acd3cd91613e173cf0efc4507775793e44
author Helena McGough <helena.mcgough@intel.com> Mon Oct 02 17:02:01 2017 +0100
committer Helena McGough <helena.mcgough@intel.com> Mon Oct 02 17:02:59 2017 +0100
tree 07a0521bd3b894d4c61a24a302e0797a9dfa00ef
parent 6a76e7045a98043170ac6517b3bf57481d5275e5

Small bug fix in producer.py

Signed-off-by: Helena McGough <helena.mcgough@intel.com>

core/message_bus/producer.py

diff --git a/core/message_bus/producer.py b/core/message_bus/producer.py
index f5abce2..1b0de7a 100644
--- a/core/message_bus/producer.py
+++ b/core/message_bus/producer.py
@@ -65,7 +65,7 @@
 
     def publish(self, key, value, topic=None):
         try:
-            future = self.producer.send(key, value, topic)
+            future = self.producer.send(topic=topic, key=key, value=value)
             self.producer.flush()
         except Exception:
             logging.exception("Error publishing to {} topic." .format(topic))