From 04d53749b21921c9bceebe120d170c2ee6e533af Mon Sep 17 00:00:00 2001
From: yangys <y_ys79@sina.com>
Date: 星期三, 13 十一月 2024 21:21:46 +0800
Subject: [PATCH] 增加离线检查定时任务的逻辑
---
collect/src/main/java/com/qianwen/mdc/collect/config/MqttConfig.java | 5 +++++
1 files changed, 5 insertions(+), 0 deletions(-)
diff --git a/collect/src/main/java/com/qianwen/mdc/collect/config/MqttConfig.java b/collect/src/main/java/com/qianwen/mdc/collect/config/MqttConfig.java
index e96c3f6..592d1e1 100644
--- a/collect/src/main/java/com/qianwen/mdc/collect/config/MqttConfig.java
+++ b/collect/src/main/java/com/qianwen/mdc/collect/config/MqttConfig.java
@@ -41,6 +41,10 @@
@Value("${mqtt.password:}")
private String mqttPassword;
+
+ @Value("${mqtt.timeout:1000}")
+ private int timeout;
+
@Autowired
private IOTMqttReceiveService recService;
@Autowired
@@ -73,6 +77,7 @@
DefaultMqttPahoClientFactory factory = new DefaultMqttPahoClientFactory();
MqttConnectOptions options = new MqttConnectOptions();
options.setServerURIs(new String[] { mqttHost});//"tcp://82.156.1.83:1884"
+ options.setConnectionTimeout(timeout);
if(ObjectUtil.isNotEmpty(mqttUserName)) {
options.setUserName(mqttUserName);
--
Gitblit v1.9.3