From ceb9d85c0d2aaa22f959ef6381a31ecb9f668f37 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E5=A6=82=E6=A2=A6=E6=8A=80=E6=9C=AF?= <596392912@qq.com>
Date: Wed, 1 Sep 2021 17:04:45 +0800
Subject: [PATCH] =?UTF-8?q?:sparkles:=20=E4=BC=98=E5=8C=96=E6=9C=8D?=
 =?UTF-8?q?=E5=8A=A1=E7=AB=AF=E6=B6=88=E6=81=AF=E5=A4=84=E7=90=86=E3=80=82?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../core/server/support/DefaultMqttServerProcessor.java     | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git 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
index 14790e1..fc60edc 100644
--- 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);
+		}
 	}
 
 }
-- 
GitLab