Fix subscription id before data delivery.
Issue-ID: RIC-129
Signed-off-by: subhash kumar singh <subh.singh@samsung.com>
Change-Id: I1523ed7db301d98fb40f2d48d5acc8e831094d2d
work_item = self.ei_job_result_queue.get(block=False, timeout=None)
payload = json.dumps(messages.ei_to_handler(*work_item)).encode("utf-8")
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
mdc_logger.debug("data-delivery: {}".format(payload))
# send the payload to consumer subscribed for ei_job_id
"""
push an item into the ei_job_queue
"""
"""
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)
__RMR_LOOP__.ei_job_result_queue.put(item)
- mdc_logger.debug("after queue")
def healthcheck_rmr_thread(seconds=30):
def healthcheck_rmr_thread(seconds=30):