注释不必要的mq发送

This commit is contained in:
lnk
2026-06-08 10:50:03 +08:00
parent 465e304085
commit cd92ea09f1

View File

@@ -2863,7 +2863,7 @@ void processGGIO_start_data_end(char* mp_id,char* fullname,double v,long long ti
printf("transfer json ggio data: %s==%s \n", KafkaData.strText.toStdString().c_str(), fullname); printf("transfer json ggio data: %s==%s \n", KafkaData.strText.toStdString().c_str(), fullname);
kafka_data_list_mutex.lock(); //加锁 kafka_data_list_mutex.lock(); //加锁
kafka_data_list.append(KafkaData); //添加 kafka发送链表 //kafka_data_list.append(KafkaData); //添加 kafka发送链表
kafka_data_list_mutex.unlock(); //解锁 kafka_data_list_mutex.unlock(); //解锁
} }