From bdc4e45ca354f1eaa372bd448e632e5b74017973 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: Tue, 15 Sep 2020 21:18:51 +0800
Subject: [PATCH] =?UTF-8?q?:sparkles:=20=E7=AE=80=E5=8C=96=20PINGRESP?=
 =?UTF-8?q?=E3=80=82?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../net/dreamlu/iot/mqtt/server/MqttBrokerProcessorImpl.java | 5 +----
 1 file changed, 1 insertion(+), 4 deletions(-)

diff --git a/mica-mqtt-example/src/main/java/net/dreamlu/iot/mqtt/server/MqttBrokerProcessorImpl.java b/mica-mqtt-example/src/main/java/net/dreamlu/iot/mqtt/server/MqttBrokerProcessorImpl.java
index a28426c..e48b4e2 100644
--- a/mica-mqtt-example/src/main/java/net/dreamlu/iot/mqtt/server/MqttBrokerProcessorImpl.java
+++ b/mica-mqtt-example/src/main/java/net/dreamlu/iot/mqtt/server/MqttBrokerProcessorImpl.java
@@ -133,10 +133,7 @@ public class MqttBrokerProcessorImpl implements MqttServerProcessor {
 	public void processPingReq(ChannelContext context) {
 		String clientId = context.getBsId();
 		log.debug("PINGREQ - clientId: {}", clientId);
-		MqttMessage message = MqttMessageFactory.newMessage(
-			new MqttFixedHeader(MqttMessageType.PINGRESP, false, MqttQoS.AT_MOST_ONCE, false, 0),
-			null, null);
-		Tio.send(context, message);
+		Tio.send(context, MqttMessage.PINGRESP);
 	}
 
 	@Override
-- 
GitLab