From 3c2d5eeb30fb7e249d52ce04a8924c190af1fbc6 Mon Sep 17 00:00:00 2001 From: Igor Kulikov Date: Tue, 11 Jul 2023 16:15:51 +0300 Subject: [PATCH] Minor fix --- .../main/java/org/thingsboard/rule/engine/aws/sns/TbSnsNode.java | 1 - 1 file changed, 1 deletion(-) diff --git a/rule-engine/rule-engine-components/src/main/java/org/thingsboard/rule/engine/aws/sns/TbSnsNode.java b/rule-engine/rule-engine-components/src/main/java/org/thingsboard/rule/engine/aws/sns/TbSnsNode.java index bb93cb8d63..a8a1137a98 100644 --- a/rule-engine/rule-engine-components/src/main/java/org/thingsboard/rule/engine/aws/sns/TbSnsNode.java +++ b/rule-engine/rule-engine-components/src/main/java/org/thingsboard/rule/engine/aws/sns/TbSnsNode.java @@ -87,7 +87,6 @@ public class TbSnsNode extends TbAbstractExternalNode { withCallback(publishMessageAsync(ctx, tbMsg), m -> tellSuccess(ctx, m), t -> tellFailure(ctx, processException(ctx, tbMsg, t), t)); - ackIfNeeded(ctx, msg); } private ListenableFuture publishMessageAsync(TbContext ctx, TbMsg msg) {