Changed write to writeAndFlush fix issue #20

2014-01-10 10:45:56 +01:00
parent a6118b2942
commit a7619e889b
1 changed files with 1 additions and 1 deletions
@@ -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) {