Commit 34602b20 authored by zhangsen's avatar zhangsen

bug修改

parent 464dc66b
...@@ -58,7 +58,7 @@ public class AmosJxiopAnalyseApplication { ...@@ -58,7 +58,7 @@ public class AmosJxiopAnalyseApplication {
@Autowired @Autowired
private EmqKeeper emqKeeper; private EmqKeeper emqKeeper;
//本地是否执行健康指数算法开关 //本地是否执行健康指数算法开关
@Value("${openHealth:true}") @Value("${openHealth:false}")
Boolean openHealth; Boolean openHealth;
@Autowired @Autowired
private SyncESDataToTdengineMqttListener syncESDataToTdengineMqttListener; private SyncESDataToTdengineMqttListener syncESDataToTdengineMqttListener;
...@@ -79,7 +79,7 @@ public class AmosJxiopAnalyseApplication { ...@@ -79,7 +79,7 @@ public class AmosJxiopAnalyseApplication {
@Bean @Bean
public void initMqtt() throws Exception { public void initMqtt() throws Exception {
if (!openHealth) { if (openHealth) {
//订阅固化周期性数据成功的消息 //订阅固化周期性数据成功的消息
emqKeeper.subscript("sync_esdata_to_tdengine_notice", 1, syncESDataToTdengineMqttListener); emqKeeper.subscript("sync_esdata_to_tdengine_notice", 1, syncESDataToTdengineMqttListener);
} }
......
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