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 a28426ce8893816db7538ab66d2d798ec8aca9ae..e48b4e23bd2d4c3c0f9ea69c084c4c9d98534ca3 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