✨ 代码优化。

starter/mica-mqtt-client-spring-boot-starter/src/main/java/net/dreamlu/iot/mqtt/spring/client/event/MqttDisconnectEvent.java

@@ -32,14 +32,10 @@ import java.io.Serializable;
 @AllArgsConstructor
 public class MqttDisconnectEvent implements Serializable {
 
-	/**
-	 * 异常信息
-	 */
-	Throwable throwable;
 	/**
 	 * 断开原因
 	 */
-	String remark;
+	String reason;
 	/**
 	 * 是否删除连接
 	 */

starter/mica-mqtt-client-spring-boot-starter/src/main/java/net/dreamlu/iot/mqtt/spring/client/event/SpringEventMqttClientConnectListener.java

@@ -44,12 +44,15 @@ public class SpringEventMqttClientConnectListener implements IMqttClientConnectL
 
 	@Override
 	public void onDisconnect(ChannelContext channelContext, Throwable throwable, String remark, boolean isRemove) {
+		String reason;
 		if (throwable == null) {
+			reason = remark;
 			log.info("mqtt 链接断开 remark:{} isRemove:{}", remark, isRemove);
 		} else {
+			reason = remark + " Exception:" + throwable.getMessage();
 			log.error("mqtt 链接断开 remark:{} isRemove:{}", remark, isRemove, throwable);
 		}
-		eventPublisher.publishEvent(new MqttDisconnectEvent(throwable, remark, isRemove));
+		eventPublisher.publishEvent(new MqttDisconnectEvent(reason, isRemove));
 	}
 
 }