diff --git a/broker/src/main/java/org/dna/mqtt/moquette/server/netty/NettyMQTTHandler.java b/broker/src/main/java/org/dna/mqtt/moquette/server/netty/NettyMQTTHandler.java
index b7146549..acc1dd8f 100644
--- a/broker/src/main/java/org/dna/mqtt/moquette/server/netty/NettyMQTTHandler.java
+++ b/broker/src/main/java/org/dna/mqtt/moquette/server/netty/NettyMQTTHandler.java
@@ -52,7 +52,7 @@ public class NettyMQTTHandler extends ChannelInboundHandlerAdapter {
                     break;
                 case PINGREQ:
                     PingRespMessage pingResp = new PingRespMessage();
-                    ctx.write(pingResp);
+                    ctx.writeAndFlush(pingResp);
                     break;
             }
         } catch (Exception ex) {