Commit 5b9215af authored by KeYong's avatar KeYong

临时修改推送

parent cf463daa
...@@ -262,8 +262,8 @@ public class MqttReceiveServiceImpl implements MqttReceiveService { ...@@ -262,8 +262,8 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
return; return;
} }
log.info(String.format("收到mqtt消息:%s", message)); log.info(String.format("收到mqtt消息:%s", message));
// saveDataToDB(topicEntity, iotDatalist); saveDataToDB(topicEntity, iotDatalist);
realTimeDateProcessing(topicEntity, iotDatalist); // realTimeDateProcessing(topicEntity, iotDatalist);
} }
/** /**
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment