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
--- a/osm_nbi/k8s_topics.py
+++ b/osm_nbi/k8s_topics.py
@@ -1473,7 +1473,7 @@
_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 @@
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
--- a/osm_nbi/nbi.py
+++ b/osm_nbi/nbi.py
@@ -2124,6 +2124,9 @@
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,