From 0aca5d70411a95b6e6f2fb36e87613ea3960095a Mon Sep 17 00:00:00 2001 From: weidong Date: Sun, 4 Aug 2024 10:59:03 +0800 Subject: [PATCH] =?UTF-8?q?1=E3=80=81=E4=B8=A4=E4=B8=AA=E7=9B=B8=E5=90=8C?= =?UTF-8?q?=E7=9A=84mqtt=E5=AE=A2=E6=88=B7=E7=AB=AF=E5=AF=BC=E8=87=B4?= =?UTF-8?q?=E8=BF=9E=E6=8E=A5=E5=A4=B1=E8=B4=A5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/imdroid/beidou_fwd/task/GZYMQTTForwarder2.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/sec-beidou-fwd/src/main/java/com/imdroid/beidou_fwd/task/GZYMQTTForwarder2.java b/sec-beidou-fwd/src/main/java/com/imdroid/beidou_fwd/task/GZYMQTTForwarder2.java index f7e98028..268a39e4 100644 --- a/sec-beidou-fwd/src/main/java/com/imdroid/beidou_fwd/task/GZYMQTTForwarder2.java +++ b/sec-beidou-fwd/src/main/java/com/imdroid/beidou_fwd/task/GZYMQTTForwarder2.java @@ -33,10 +33,9 @@ public class GZYMQTTForwarder2 extends Forwarder { @Value("${mqtt.server.topic}") private String topic; - MQTTClient mqttClient; - @PostConstruct + //@PostConstruct void registerMe() throws MqttException { init(FORWARDER_NAME, "MQTT "+brokerUrl,2,FWD_DEVICE_ALIAS_NAME,10); mqttClient = new MQTTClient(brokerUrl, username, password,clientid); @@ -46,7 +45,7 @@ public class GZYMQTTForwarder2 extends Forwarder { /** * 每半小时转发GNSS解算结果 */ - @Scheduled(cron = "0 0/10 * * * ?") // 每10分钟执行一次 + //@Scheduled(cron = "0 0/10 * * * ?") // 每10分钟执行一次 private void forwardGnss() { logger.info("gzy mqtt forwardGnss"); forwardCurrentGnss();