Browse Source

修改mqtt配置

tags/V1.0.1^2
wanjing 1 year ago
parent
commit
56bd83ac12
1 changed files with 1 additions and 2 deletions
  1. +1
    -2
      tuoheng-service/tuoheng-admin/src/main/java/com/tuoheng/admin/mqtt/MqttProviderConfig.java

+ 1
- 2
tuoheng-service/tuoheng-admin/src/main/java/com/tuoheng/admin/mqtt/MqttProviderConfig.java View File

@@ -74,8 +74,7 @@ public class MqttProviderConfig {
client.setCallback(new MqttConsumerCallBack());
client.connect(options);

String topic = "/v1/298dd766/environment/message";
log.info("拓恒大气监测系统,订阅:topic={}", topic);
String topic = "$share/airmonitor/298dd766/environment/message";
client.subscribe(topic, 0);
} catch (MqttException e) {
e.printStackTrace();

Loading…
Cancel
Save