commit 15a1f68badbe4865b7abb3cb9ac816ed963d4b63
author tierno <alfonso.tiernosepulveda@telefonica.com> Wed Oct 16 09:00:13 2019 +0000
committer tierno <alfonso.tiernosepulveda@telefonica.com> Thu Oct 17 09:18:05 2019 +0000
tree 168924902599a6d30a99c5526f9333263abb68c6
parent c96fd6946c24dacce83fe5a14f95ab88ac54bb38

bug 864 fix operation (created/edited) published to kafka

Change-Id: Ia96573a0f79da88d2d893101cc9daed0f46bbc7a
Signed-off-by: tierno <alfonso.tiernosepulveda@telefonica.com>

osm_nbi/base_topic.py

diff --git a/osm_nbi/base_topic.py b/osm_nbi/base_topic.py
index c22833b..70c8dff 100644
--- a/osm_nbi/base_topic.py
+++ b/osm_nbi/base_topic.py
@@ -389,7 +389,7 @@
             rollback.append({"topic": self.topic, "_id": _id})
             if op_id:
                 content["op_id"] = op_id
-            self._send_msg("create", content)
+            self._send_msg("created", content)
             return _id, op_id
         except ValidationError as e:
             raise EngineException(e, HTTPStatus.UNPROCESSABLE_ENTITY)
@@ -510,7 +510,7 @@
             if op_id:
                 indata["op_id"] = op_id
             indata["_id"] = _id
-            self._send_msg("edit", indata)
+            self._send_msg("edited", indata)
             return op_id
         except ValidationError as e:
             raise EngineException(e, HTTPStatus.UNPROCESSABLE_ENTITY)