✨ mqtt client 代码优化。

563d0f8e · 如梦技术 · 85312652 · 563d0f8e
隐藏空白更改
内联并排

Showing with 5 addition and 1 deletion

mica-mqtt-core/src/main/java/net/dreamlu/iot/mqtt/core/client/DefaultMqttClientProcessor.java ...amlu/iot/mqtt/core/client/DefaultMqttClientProcessor.java +5 -1

未找到文件。
--- 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);
+			}
 		});
 	}