From d1b1b9b55c530660e6a0205e37378b845ef7bfe5 Mon Sep 17 00:00:00 2001
From: "Stephan.Praetsch" <stephan.praetsch@unite.eu>
Date: Thu, 13 Jun 2024 08:40:57 +0200
Subject: [PATCH] replace AtomicBoolean with normal boolean because used in
 synchronized methods

---
 .../sqs/utils/message/handling/MessageWrapper.java         | 7 +++----
 1 file changed, 3 insertions(+), 4 deletions(-)

diff --git a/src/main/java/com/mercateo/sqs/utils/message/handling/MessageWrapper.java b/src/main/java/com/mercateo/sqs/utils/message/handling/MessageWrapper.java
index 8e8ead8..ce167bb 100644
--- a/src/main/java/com/mercateo/sqs/utils/message/handling/MessageWrapper.java
+++ b/src/main/java/com/mercateo/sqs/utils/message/handling/MessageWrapper.java
@@ -6,7 +6,6 @@
 import io.awspring.cloud.messaging.listener.Acknowledgment;
 
 import java.util.concurrent.TimeUnit;
-import java.util.concurrent.atomic.AtomicBoolean;
 
 import lombok.Getter;
 import lombok.NonNull;
@@ -22,7 +21,7 @@ public class MessageWrapper<I> {
     @Getter
     private final Message<I> message;
 
-    private final AtomicBoolean acknowledged = new AtomicBoolean(false);
+    private boolean acknowledged = false;
 
     public String getMessageId() {
         return message.getHeaders().get("MessageId", String.class);
@@ -39,11 +38,11 @@ public synchronized void acknowledge() {
             throw new NullPointerException("there is no \"Acknowledgment\" in the message headers");
         }
         acknowledgment.acknowledge().get(2, TimeUnit.MINUTES);
-        acknowledged.set(true);
+        acknowledged = true;
     }
 
     public synchronized void changeMessageVisibility(AmazonSQS sqsClient, ChangeMessageVisibilityRequest request) {
-        if (acknowledged.get()) {
+        if (acknowledged) {
             return;
         }
         sqsClient.changeMessageVisibility(request);