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 index 46a7e92..cb20932 100644 --- 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 defaultSqsListenerContainerFac return SqsMessageListenerContainerFactory .builder() .configure(options -> options + .acknowledgementMode(AcknowledgementMode.ON_SUCCESS) .maxConcurrentMessages(10) .maxMessagesPerPoll(10)) .sqsAsyncClient(sqsAsyncClient())