acknowledge in error case

hivemq · Sep 21, 2023 · cdfe798 · cdfe798
1 parent a9905db
commit cdfe798
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 0 deletions.
diff --git a/src/main/java/com/hivemq/cli/mqtt/SubscribeMqtt3PublishCallback.java b/src/main/java/com/hivemq/cli/mqtt/SubscribeMqtt3PublishCallback.java
@@ -68,6 +68,7 @@ public void accept(final @NotNull Mqtt3Publish mqtt3Publish) {
                     mqtt3Publish);
         } catch (final Exception e) {
             Logger.error("An error occurred while processing an incoming PUBLISH.", e);
+            mqtt3Publish.acknowledge();
             return;
         }
 

diff --git a/src/main/java/com/hivemq/cli/mqtt/SubscribeMqtt5PublishCallback.java b/src/main/java/com/hivemq/cli/mqtt/SubscribeMqtt5PublishCallback.java
@@ -68,6 +68,7 @@ public void accept(final @NotNull Mqtt5Publish mqtt5Publish) {
                     mqtt5Publish);
         } catch (final Exception e) {
             Logger.error("An error occurred while processing an incoming PUBLISH.", e);
+            mqtt5Publish.acknowledge();
             return;
         }