added queue error policy

pagopa · Nov 16, 2023 · 6e8a8a1 · 6e8a8a1
1 parent e41e7b8
commit 6e8a8a1
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/src/main/java/it/pagopa/interop/signalhub/persister/config/AwsBeanBuilder.java b/src/main/java/it/pagopa/interop/signalhub/persister/config/AwsBeanBuilder.java
@@ -2,6 +2,7 @@
 
 import io.awspring.cloud.sqs.config.SqsBootstrapConfiguration;
 import io.awspring.cloud.sqs.config.SqsMessageListenerContainerFactory;
+import io.awspring.cloud.sqs.listener.acknowledgement.handler.AcknowledgementMode;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.context.annotation.Bean;
@@ -35,6 +36,7 @@ public SqsMessageListenerContainerFactory<Object> defaultSqsListenerContainerFac
         return SqsMessageListenerContainerFactory
                 .builder()
                 .configure(options -> options
+                        .acknowledgementMode(AcknowledgementMode.ON_SUCCESS)
                         .maxConcurrentMessages(10)
                         .maxMessagesPerPoll(10))
                 .sqsAsyncClient(sqsAsyncClient())