From 310741ce87882a30f937d0c95f1f365ad5a00052 Mon Sep 17 00:00:00 2001 From: "zhczyx@163.com" Date: Wed, 17 Dec 2025 22:47:24 +0800 Subject: [PATCH] =?UTF-8?q?=E5=8E=BB=E9=99=A4mqtt=E6=96=B0=E7=89=88?= =?UTF-8?q?=E6=9C=AC=E6=B2=A1=E6=9C=89=E7=9A=84=E6=96=B9=E6=B3=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../datacenter/receiver/service/impl/MQTTServiceImpl.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/java/com/techsor/datacenter/receiver/service/impl/MQTTServiceImpl.java b/src/main/java/com/techsor/datacenter/receiver/service/impl/MQTTServiceImpl.java index c66e2ae..3cb4c2b 100644 --- a/src/main/java/com/techsor/datacenter/receiver/service/impl/MQTTServiceImpl.java +++ b/src/main/java/com/techsor/datacenter/receiver/service/impl/MQTTServiceImpl.java @@ -218,7 +218,7 @@ class MqttConsumer { } adapter.setCompletionTimeout(5000); - adapter.setRecoveryInterval(5000); +// adapter.set(5000); adapter.setConverter(new DefaultPahoMessageConverter()); if (!Objects.nonNull(config.getQos())){ adapter.setQos(1);