async def cb_nr_subscription_handler(msg: nats.aio.client.Msg):
    'Use Callback to process Queue Msg objects.'
    try:
        logger.info('Received raw message seq:%s, data=  %s', msg.sequence, msg.data.decode())
        event_message = json.loads(msg.data.decode('utf-8'))
        logger.debug('Event Message Received: %s', event_message)
        (await process_event(event_message, FLASK_APP))
    except Exception:
        logger.error('Queue Error: %s', json.dumps(event_message), exc_info=True)
Use Callback to process Queue Msg objects.
async def cb_nr_subscription_handler(msg: nats.aio.client.Msg):
    
    try:
        logger.info('Received raw message seq:%s, data=  %s', msg.sequence, msg.data.decode())
        event_message = json.loads(msg.data.decode('utf-8'))
        logger.debug('Event Message Received: %s', event_message)
        (await process_event(event_message, FLASK_APP))
    except Exception:
        logger.error('Queue Error: %s', json.dumps(event_message), exc_info=True)