From a7619e889b8405c1148edf2a52591978a2f09f3b Mon Sep 17 00:00:00 2001
From: andrea <andrea@samarcanda>
Date: Fri, 10 Jan 2014 10:45:56 +0100
Subject: [PATCH] Changed write to writeAndFlush fix issue #20

---
 .../org/dna/mqtt/moquette/server/netty/NettyMQTTHandler.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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) {