Minor fix

3 years ago · 3c2d5eeb30
1 changed files with 0 additions and 1 deletions
--- 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<TbMsg> publishMessageAsync(TbContext ctx, TbMsg msg) {