提交 b9b0c454 编写于 作者: 如梦技术's avatar 如梦技术 🐛

mqtt server topicFilters 校验。

上级 3610a36b
......@@ -245,7 +245,7 @@ public class DefaultMqttServerProcessor implements MqttServerProcessor {
// 1. 校验订阅的 topicFilter
List<MqttTopicSubscription> topicSubscriptions = message.payload().topicSubscriptions();
if (!authHandler.isValidSubscribe(topicSubscriptions)) {
logger.error("Subscribe - clientId:{} topicFilters verification failed", messageId);
logger.error("Subscribe - clientId:{} topicFilters:{} verification failed messageId:{}", clientId, topicSubscriptions, messageId);
// 3. 返回 ack
MqttMessage subAckMessage = MqttMessageBuilders.subAck()
.addGrantedQos(MqttQoS.FAILURE)
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册