✨ mica-mqtt 代码优化

README.md

@@ -54,7 +54,7 @@
 <dependency>
   <groupId>net.dreamlu</groupId>
   <artifactId>mica-mqtt-spring-boot-starter</artifactId>
-  <version>1.2.6</version>
+  <version>1.2.7</version>
 </dependency>
 ```
 
@@ -65,7 +65,7 @@
 <dependency>
   <groupId>net.dreamlu</groupId>
   <artifactId>mica-mqtt-core</artifactId>
-  <version>1.2.6</version>
+  <version>1.2.7</version>
 </dependency>
 ```
 

mica-mqtt-core/src/main/java/net/dreamlu/iot/mqtt/core/client/MqttClient.java

@@ -363,12 +363,14 @@ public final class MqttClient {
 		if (payload == null) {
 			payload = ByteBuffer.allocate(0);
 		}
-		MqttMessageBuilders.PublishBuilder publishBuilder = MqttMessageBuilders.publish()
-			.topicName(topic)
+		MqttMessageBuilders.PublishBuilder publishBuilder = MqttMessageBuilders.publish();
+		// 自定义配置
+		builder.accept(publishBuilder);
+		// 内置
+		publishBuilder.topicName(topic)
 			.payload(payload)
 			.messageId(messageId)
 			.qos(qos);
-		builder.accept(publishBuilder);
 		MqttPublishMessage message = publishBuilder.build();
 		boolean result = Tio.send(getContext(), message);
 		logger.info("MQTT Topic:{} qos:{} retain:{} publish result:{}", topic, qos, publishBuilder.isRetained(), result);