提交 87691568 编写于 作者: 浅梦2013's avatar 浅梦2013

mica-mqtt-spring-boot-starter `@MqttClientSubscribe` value 改为数组,支持同时订阅多 topic。

上级 0aade5ac
......@@ -2,6 +2,7 @@
## 发行版本
### v1.2.3 - 2022-01-03
- :sparkles: mica-mqtt-spring-boot-starter `@MqttClientSubscribe` value 改为数组,支持同时订阅多 topic。
- :sparkles: mica-mqtt-core 缓存 TopicFilter Pattern。
- :sparkles: mica-mqtt-core 优化客户端和服务端订阅逻辑 `IMqttServerSubscribeValidator` 接口调整。
- :sparkles: mica-mqtt client 添加批量订阅。
......
......@@ -35,7 +35,7 @@ public @interface MqttClientSubscribe {
*
* @return topic filter
*/
String value();
String[] value();
/**
* 订阅的 qos
......
......@@ -69,7 +69,7 @@ public class MqttClientSubscribeDetector implements BeanPostProcessor {
throw new IllegalArgumentException("@MqttClientSubscribe on method " + method + " parameter type must String and ByteBuffer.");
}
// 4. 订阅
mqttClient.subscribe(subscribe.qos(), subscribe.value(), (topic, payload) ->
mqttClient.subscribe(subscribe.value(), subscribe.qos(), (topic, payload) ->
ReflectionUtils.invokeMethod(method, bean, topic, payload)
);
}
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册