THENG
/
a-tuoheng-device
6
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

xx

This commit is contained in:
孙小云 2026-01-28 14:52:30 +08:00
parent 035e558ef7
commit 9999fd922b
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/main/java/com/ruoyi/device/domain/impl/djimqtt/service/DjiMqttClientService.java
View File

@ -135,11 +135,11 @@ public class DjiMqttClientService {
String topic = (String) message.getHeaders().get("mqtt_receivedTopic"); String topic = (String) message.getHeaders().get("mqtt_receivedTopic");
String payload = (String) message.getPayload(); String payload = (String) message.getPayload();
if (topic != null && payload != null) { if (topic != null) {
messageHandler.handleMessage(topic, payload); messageHandler.handleMessage(topic, payload);
} }
} catch (Exception e) { } catch (Exception e) {
log.error("MQTT客户端[{}]处理消息失败: ", config.getClientId(), e.getMessage(), e); log.error("MQTT客户端[{}]处理消息失败: {}", config.getClientId(), e.getMessage(), e);
} }
} }