X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=a1%2Fa1rmr.py;fp=a1%2Fa1rmr.py;h=f66782423f083767ee96798422bc9172fd059fae;hb=d74edc5904517af2df6e214e1ecee8d84f42e52b;hp=5a300e8673302e9ccb48aee4a51c38f90f9f8ce4;hpb=7f64be0fde75858b41905cb35d49c23b571b48c1;p=ric-plt%2Fa1.git

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):