code-image-backup-public/fastbee
1
0
Fork 0
mirror of https://gitee.com/beecue/fastbee.git synced 2025-12-18 00:45:55 +08:00
Code Issues Packages Projects Releases Wiki Activity

更新配置

Browse Source
This commit is contained in:
kerwincui
2022-03-23 14:18:44 +08:00
parent 5c79a1d839
commit 5852c2ae20
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
springboot/wumei-iot/src/main/java/com/ruoyi/iot/mqtt/EmqxService.java
View File

@@ -84,7 +84,7 @@ public class EmqxService {
/**测试线程池使用*/ /**测试线程池使用*/
logger.info("====>>>>线程名--{}",Thread.currentThread().getName()); logger.info("====>>>>线程名--{}",Thread.currentThread().getName());
/**模拟耗时操作*/ /**模拟耗时操作*/
Thread.sleep(1000); // Thread.sleep(1000);
// subscribe后得到的消息会执行到这里面 // subscribe后得到的消息会执行到这里面
String message = new String(mqttMessage.getPayload()); String message = new String(mqttMessage.getPayload());
logger.info("接收消息主题 : " + topic); logger.info("接收消息主题 : " + topic);