Commit 92501530 authored by maoying's avatar maoying

修改推送接口

parent d0043002
...@@ -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