✨ 优化服务端消息处理。

ceb9d85c · 如梦技术 · fbccedbe · ceb9d85c
隐藏空白更改
内联并排

Showing with 5 addition and 1 deletion

mica-mqtt-core/src/main/java/net/dreamlu/iot/mqtt/core/server/support/DefaultMqttServerProcessor.java .../mqtt/core/server/support/DefaultMqttServerProcessor.java +5 -1

未找到文件。
--- a/mica-mqtt-core/src/main/java/net/dreamlu/iot/mqtt/core/server/support/DefaultMqttServerProcessor.java
+++ b/mica-mqtt-core/src/main/java/net/dreamlu/iot/mqtt/core/server/support/DefaultMqttServerProcessor.java
@@ -331,7 +331,11 @@ public class DefaultMqttServerProcessor implements MqttServerProcessor {
 			}
 		}
 		// 2. 消息发布
-		messageListener.onMessage(clientId, topicName, mqttQoS, payload);
+		try {
+			messageListener.onMessage(clientId, topicName, mqttQoS, payload);
+		} catch (Throwable e) {
+			logger.error(e.getMessage(), e);
+		}
 	}

 }