From 563d0f8eb989222f74c3b4e27f6b2b1cc30f20d4 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: Tue, 31 Aug 2021 16:20:52 +0800
Subject: [PATCH] =?UTF-8?q?:sparkles:=20mqtt=20client=20=E4=BB=A3=E7=A0=81?=
 =?UTF-8?q?=E4=BC=98=E5=8C=96=E3=80=82?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../iot/mqtt/core/client/DefaultMqttClientProcessor.java    | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/mica-mqtt-core/src/main/java/net/dreamlu/iot/mqtt/core/client/DefaultMqttClientProcessor.java b/mica-mqtt-core/src/main/java/net/dreamlu/iot/mqtt/core/client/DefaultMqttClientProcessor.java
index e3a3334..2b367ce 100644
--- a/mica-mqtt-core/src/main/java/net/dreamlu/iot/mqtt/core/client/DefaultMqttClientProcessor.java
+++ b/mica-mqtt-core/src/main/java/net/dreamlu/iot/mqtt/core/client/DefaultMqttClientProcessor.java
@@ -259,7 +259,11 @@ public class DefaultMqttClientProcessor implements IMqttClientProcessor {
 		subscriptionList.forEach(subscription -> {
 			IMqttClientMessageListener listener = subscription.getListener();
 			payload.rewind();
-			listener.onMessage(topicName, payload);
+			try {
+				listener.onMessage(topicName, payload);
+			} catch (Throwable e) {
+				logger.error(e.getMessage(), e);
+			}
 		});
 	}
 
-- 
GitLab