|
|
|
|
@ -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);
|
|
|
|
|
|