diff --git a/sec-beidou-fwd/src/main/java/com/imdroid/beidou_fwd/task/ZNYMQTTForwarder.java b/sec-beidou-fwd/src/main/java/com/imdroid/beidou_fwd/task/ZNYMQTTForwarder.java index e3ed916d..9c2f1157 100644 --- a/sec-beidou-fwd/src/main/java/com/imdroid/beidou_fwd/task/ZNYMQTTForwarder.java +++ b/sec-beidou-fwd/src/main/java/com/imdroid/beidou_fwd/task/ZNYMQTTForwarder.java @@ -27,7 +27,7 @@ import java.util.List; @Configuration @EnableScheduling public class ZNYMQTTForwarder extends Forwarder { - static final String FORWARDER_NAME = "贵州交勘院MQTT"; + static final String FORWARDER_NAME = "中南院MQTT"; @Value("${zny.mqtt.brokerUrl}") private String brokerUrl; @Value("${zny.mqtt.username}") @@ -45,9 +45,9 @@ public class ZNYMQTTForwarder extends Forwarder { @PostConstruct void registerMe() throws MqttException { - init(FORWARDER_NAME, "MQTT "+brokerUrl,2,FWD_DEVICE_ALIAS_NAME,30); + //init(FORWARDER_NAME, "MQTT "+brokerUrl,4,FWD_DEVICE_ALIAS_NAME,30); mqttClient = new MQTTClient(brokerUrl, username, password,clientid); - mqttClient.connect(); + //mqttClient.connect(); } /**