From 5852c2ae201c22c32d4b19d40a717b95c7699ef9 Mon Sep 17 00:00:00 2001 From: kerwincui <164770707@qq.com> Date: Wed, 23 Mar 2022 14:18:44 +0800 Subject: [PATCH] =?UTF-8?q?=E6=9B=B4=E6=96=B0=E9=85=8D=E7=BD=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../wumei-iot/src/main/java/com/ruoyi/iot/mqtt/EmqxService.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/springboot/wumei-iot/src/main/java/com/ruoyi/iot/mqtt/EmqxService.java b/springboot/wumei-iot/src/main/java/com/ruoyi/iot/mqtt/EmqxService.java index 25cd4098..98de2000 100644 --- a/springboot/wumei-iot/src/main/java/com/ruoyi/iot/mqtt/EmqxService.java +++ b/springboot/wumei-iot/src/main/java/com/ruoyi/iot/mqtt/EmqxService.java @@ -84,7 +84,7 @@ public class EmqxService { /**测试线程池使用*/ logger.info("====>>>>线程名--{}",Thread.currentThread().getName()); /**模拟耗时操作*/ - Thread.sleep(1000); + // Thread.sleep(1000); // subscribe后得到的消息会执行到这里面 String message = new String(mqttMessage.getPayload()); logger.info("接收消息主题 : " + topic);