From eec4f5a403ead93b595ac9ab161e9b0746d7a06e Mon Sep 17 00:00:00 2001
From: vzikratyi <vzikratyi@thingsboard.io>
Date: Tue, 15 Jun 2021 17:00:21 +0300
Subject: [PATCH] Removed unnecessary retain of PUBLISH message for QoS 2

---
 .../src/main/java/org/thingsboard/mqtt/MqttChannelHandler.java   | 1 -
 1 file changed, 1 deletion(-)

diff --git a/netty-mqtt/src/main/java/org/thingsboard/mqtt/MqttChannelHandler.java b/netty-mqtt/src/main/java/org/thingsboard/mqtt/MqttChannelHandler.java
index 7ae7d5989d..534883f337 100644
--- a/netty-mqtt/src/main/java/org/thingsboard/mqtt/MqttChannelHandler.java
+++ b/netty-mqtt/src/main/java/org/thingsboard/mqtt/MqttChannelHandler.java
@@ -200,7 +200,6 @@ final class MqttChannelHandler extends SimpleChannelInboundHandler<MqttMessage>
 
                     MqttIncomingQos2Publish incomingQos2Publish = new MqttIncomingQos2Publish(message);
                     this.client.getQos2PendingIncomingPublishes().put(message.variableHeader().packetId(), incomingQos2Publish);
-                    message.payload().retain();
 
                     channel.writeAndFlush(pubrecMessage);
                 }