Parcourir la source

update:mqtt suback回调给csdk用户

alienwalker il y a 1 an
Parent
commit
0d592f7b5d

+ 4 - 0
components/network/libemqtt/luat_lib_mqtt.c

@@ -176,6 +176,10 @@ int32_t luatos_mqtt_callback(lua_State *L, void* ptr){
             }
             break;
         }
+		case MQTT_MSG_SUBACK:
+			break;
+		case MQTT_MSG_UNSUBACK:
+			break;
 		default : {
 			LLOGD("l_mqtt_callback error arg1:%d",msg->arg1);
             break;

+ 4 - 0
components/network/libemqtt/luat_mqtt_client.c

@@ -351,10 +351,14 @@ static int luat_mqtt_msg_cb(luat_mqtt_ctrl_t *mqtt_ctrl) {
 		}
         case MQTT_MSG_SUBACK : {
 			LLOGD("MQTT_MSG_SUBACK");
+			msg_id = mqtt_parse_msg_id(mqtt_ctrl->mqtt_packet_buffer);
+			l_luat_mqtt_msg_cb(mqtt_ctrl, MQTT_MSG_SUBACK, msg_id);
             break;
         }
 		case MQTT_MSG_UNSUBACK : {
 			LLOGD("MQTT_MSG_UNSUBACK");
+			msg_id = mqtt_parse_msg_id(mqtt_ctrl->mqtt_packet_buffer);
+			l_luat_mqtt_msg_cb(mqtt_ctrl, MQTT_MSG_UNSUBACK, msg_id);
             break;
         }
         case MQTT_MSG_PINGRESP : {