diff --git a/ruoyi-modules/ruoyi-hazard/src/main/java/org/dromara/hazard/handler/HazardMqttMessageHandler.java b/ruoyi-modules/ruoyi-hazard/src/main/java/org/dromara/hazard/handler/HazardMqttMessageHandler.java index 9ee357745..652922e7a 100644 --- a/ruoyi-modules/ruoyi-hazard/src/main/java/org/dromara/hazard/handler/HazardMqttMessageHandler.java +++ b/ruoyi-modules/ruoyi-hazard/src/main/java/org/dromara/hazard/handler/HazardMqttMessageHandler.java @@ -60,7 +60,7 @@ public class HazardMqttMessageHandler implements MqttMessageHandler { topic, message.getQos(), message.isRetained(), payload); // TODO: 根据不同的主题分发到不同的业务处理方法 - if (topic.equals("iot-hazard-server")) { + if (topic.equals("iot_hazard_server")) { handleHazardMessage(topic, payload); } else if (topic.equals("status/online")){ handleOnlineMessage(topic, payload);