From 037d1797accb623539b23494fc31146bcd169d78 Mon Sep 17 00:00:00 2001
From: zbeacon <ibarkov.ua@gmail.com>
Date: Mon, 8 Nov 2021 10:43:22 +0200
Subject: [PATCH] Fix for mqtt duplication sending on sent failed

---
 .../src/main/java/org/thingsboard/mqtt/MqttClientImpl.java       | 1 +
 1 file changed, 1 insertion(+)

diff --git a/netty-mqtt/src/main/java/org/thingsboard/mqtt/MqttClientImpl.java b/netty-mqtt/src/main/java/org/thingsboard/mqtt/MqttClientImpl.java
index fdc44dbb42..827d9fa4cf 100644
--- a/netty-mqtt/src/main/java/org/thingsboard/mqtt/MqttClientImpl.java
+++ b/netty-mqtt/src/main/java/org/thingsboard/mqtt/MqttClientImpl.java
@@ -368,6 +368,7 @@ final class MqttClientImpl implements MqttClient {
         if (channelFuture != null) {
             pendingPublish.setSent(true);
             if (channelFuture.cause() != null) {
+                this.pendingPublishes.remove(pendingPublish.getMessageId());
                 future.setFailure(channelFuture.cause());
                 return future;
             }