✨ 开始 1.3.8-SNAPSHOT

example/mica-mqtt-client-spring-boot-example/src/main/java/net/dreamlu/iot/mqtt/client/listener/MqttClientSubscribeListener.java

@@ -28,5 +28,12 @@ public class MqttClientSubscribeListener {
 		logger.info("topic:{} payload:{}", topic, ByteBufferUtil.toString(payload));
 	}
 
+	@MqttClientSubscribe("/sys/${productKey}/${deviceName}/thing/sub/register")
+	public void thingSubRegister(String topic, ByteBuffer payload) {
+		// 1.3.8 开始支持，@MqttClientSubscribe 注解支持 ${} 变量替换，会默认替换成 +
+		// 注意：mica-mqtt 会先从 Spring boot 配置中替换参数 ${}，如果存在配置会优先被替换。
+		logger.info("topic:{} payload:{}", topic, ByteBufferUtil.toString(payload));
+	}
+
 }
 

pom.xml

@@ -13,7 +13,7 @@
 
     <properties>
         <!-- mica-mqtt version -->
-        <revision>1.3.7</revision>
+        <revision>1.3.8-SNAPSHOT</revision>
         <!-- java version -->
         <java.version>1.8</java.version>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>

starter/mica-mqtt-client-spring-boot-starter/README.md

@@ -111,6 +111,13 @@ public class MqttClientSubscribeListener {
 		logger.info("topic:{} payload:{}", topic, ByteBufferUtil.toString(payload));
 	}
 
+	@MqttClientSubscribe("/sys/${productKey}/${deviceName}/thing/sub/register")
+	public void thingSubRegister(String topic, ByteBuffer payload) {
+		// 1.3.8 开始支持，@MqttClientSubscribe 注解支持 ${} 变量替换，会默认替换成 +
+		// 注意：mica-mqtt 会先从 Spring boot 配置中替换参数 ${}，如果存在配置会优先被替换。
+		logger.info("topic:{} payload:{}", topic, ByteBufferUtil.toString(payload));
+	}
+
 }
 ```