Feature 11073: Fix send of kafka message

Change-Id: Ie3f5d58995778e3b2db700698996c868899b8f0f
Signed-off-by: garciadeblas <gerardo.garciadeblas@telefonica.com>

diff --git a/osm_nbi/k8s_topics.py b/osm_nbi/k8s_topics.py
index 23faf29..a1d21b7 100644 (file)
--- a/osm_nbi/k8s_topics.py
+++ b/osm_nbi/k8s_topics.py
@@ -1473,7 +1473,7 @@ class AppInstanceTopic(ACMTopic):
 
         _id = self.db.create(self.topic, content)
         rollback.append({"topic": self.topic, "_id": _id})
-        self._send_msg("create", content=content)
+        self._send_msg("create", {"appinstance": _id, "operation_id": op_id})
         return _id, op_id
 
     def update_oka_usage_state(self, session, oka_id):
@@ -1556,8 +1556,7 @@ class AppInstanceTopic(ACMTopic):
             operation_params,
         )
         self.db.set_one(self.topic, {"_id": _id}, data)
-        data = {"appinstance": _id, "operation_id": op_id}
-        self._send_msg(item, data)
+        self._send_msg(item, {"appinstance": _id, "operation_id": op_id})
         return op_id
 
     def delete(self, session, _id, not_send_msg=None):

diff --git a/osm_nbi/nbi.py b/osm_nbi/nbi.py
index 09ae05d..f723ff5 100644 (file)
--- a/osm_nbi/nbi.py
+++ b/osm_nbi/nbi.py
@@ -2124,6 +2124,9 @@ class Server(object):
                         self._set_location_header(main_topic, version, topic, _id)
                         outdata = {"_id": _id, "id": _id}
                 else:
+                    self.logger.debug(
+                        "Creating new item in topic {}".format(engine_topic)
+                    )
                     _id, op_id = self.engine.new_item(
                         rollback,
                         engine_session,