diff --git a/components/network/libemqtt/luat_mqtt_client.c b/components/network/libemqtt/luat_mqtt_client.c index bf794abb..6378a00f 100644 --- a/components/network/libemqtt/luat_mqtt_client.c +++ b/components/network/libemqtt/luat_mqtt_client.c @@ -288,9 +288,9 @@ static int luat_mqtt_msg_cb(luat_mqtt_ctrl_t *mqtt_ctrl) { } case MQTT_MSG_PUBLISH : { LLOGD("MQTT_MSG_PUBLISH"); + qos = MQTTParseMessageQos(mqtt_ctrl->mqtt_packet_buffer); #ifdef __LUATOS__ const uint8_t* ptr; - qos = MQTTParseMessageQos(mqtt_ctrl->mqtt_packet_buffer); uint16_t topic_len = mqtt_parse_pub_topic_ptr(mqtt_ctrl->mqtt_packet_buffer, &ptr); uint16_t payload_len = mqtt_parse_pub_msg_ptr(mqtt_ctrl->mqtt_packet_buffer, &ptr); luat_mqtt_msg_t *mqtt_msg = (luat_mqtt_msg_t *)luat_heap_malloc(sizeof(luat_mqtt_msg_t)+topic_len+payload_len);