From b9b0c4541b00c8c439ccf085d1504ea305beb33f Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=A6=82=E6=A2=A6=E6=8A=80=E6=9C=AF?= <596392912@qq.com> Date: Wed, 1 Sep 2021 18:19:52 +0800 Subject: [PATCH] =?UTF-8?q?:sparkles:=20mqtt=20server=20topicFilters=20?= =?UTF-8?q?=E6=A0=A1=E9=AA=8C=E3=80=82?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../mqtt/core/server/support/DefaultMqttServerProcessor.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/mica-mqtt-core/src/main/java/net/dreamlu/iot/mqtt/core/server/support/DefaultMqttServerProcessor.java b/mica-mqtt-core/src/main/java/net/dreamlu/iot/mqtt/core/server/support/DefaultMqttServerProcessor.java index 21e7b55..25f9eef 100644 --- a/mica-mqtt-core/src/main/java/net/dreamlu/iot/mqtt/core/server/support/DefaultMqttServerProcessor.java +++ b/mica-mqtt-core/src/main/java/net/dreamlu/iot/mqtt/core/server/support/DefaultMqttServerProcessor.java @@ -245,7 +245,7 @@ public class DefaultMqttServerProcessor implements MqttServerProcessor { // 1. 校验订阅的 topicFilter List 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) -- GitLab