From: subhash kumar singh <subh.singh@samsung.com>
Date: Sun, 6 Jun 2021 20:01:55 +0000 (+0530)
Subject: Fix subscription id before data delivery
X-Git-Tag: 2.5.0~4
X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=commitdiff_plain;h=d74edc5904517af2df6e214e1ecee8d84f42e52b;p=ric-plt%2Fa1.git

Fix subscription id before data delivery

Fix subscription id before data delivery.

Issue-ID: RIC-129
Signed-off-by: subhash kumar singh <subh.singh@samsung.com>
Change-Id: I1523ed7db301d98fb40f2d48d5acc8e831094d2d
---

diff --git a/a1/a1rmr.py b/a1/a1rmr.py
index 5a300e8..f667824 100644
--- a/a1/a1rmr.py
+++ b/a1/a1rmr.py
@@ -172,7 +172,7 @@ class _RmrLoop:
 
             work_item = self.ei_job_result_queue.get(block=False, timeout=None)
             payload = json.dumps(messages.ei_to_handler(*work_item)).encode("utf-8")
-            ei_job_id = int(payload.get("ei_job_id"))
+            ei_job_id = int(work_item[0])
             mdc_logger.debug("data-delivery: {}".format(payload))
 
             # send the payload to consumer subscribed for ei_job_id
@@ -323,9 +323,8 @@ def queue_ei_job_result(item):
     """
     push an item into the ei_job_queue
     """
-    mdc_logger.debug("before queue {0}".format(item))
+    mdc_logger.debug("queuing data delivery item {0}".format(item))
     __RMR_LOOP__.ei_job_result_queue.put(item)
-    mdc_logger.debug("after queue")
 
 
 def healthcheck_rmr_thread(seconds=30):