From 78f75440a0edfac88f0e648f6e44426d5e895b0c Mon Sep 17 00:00:00 2001
From: Igor Kulikov <ikulikov@thingsboard.io>
Date: Tue, 23 Jul 2019 17:29:34 +0300
Subject: [PATCH] MqttTransportHandler: Use default channelReadComplete
 implementation to avoid memory leaks.

---
 .../server/transport/mqtt/MqttTransportHandler.java          | 5 -----
 1 file changed, 5 deletions(-)

diff --git a/common/transport/mqtt/src/main/java/org/thingsboard/server/transport/mqtt/MqttTransportHandler.java b/common/transport/mqtt/src/main/java/org/thingsboard/server/transport/mqtt/MqttTransportHandler.java
index d7d2281b4f..ac1f07c680 100644
--- a/common/transport/mqtt/src/main/java/org/thingsboard/server/transport/mqtt/MqttTransportHandler.java
+++ b/common/transport/mqtt/src/main/java/org/thingsboard/server/transport/mqtt/MqttTransportHandler.java
@@ -421,11 +421,6 @@ public class MqttTransportHandler extends ChannelInboundHandlerAdapter implement
         return new MqttConnAckMessage(mqttFixedHeader, mqttConnAckVariableHeader);
     }
 
-    @Override
-    public void channelReadComplete(ChannelHandlerContext ctx) {
-        ctx.flush();
-    }
-
     @Override
     public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
         log.error("[{}] Unexpected Exception", sessionId, cause);