Fix AckMPTest RC when delayed ack asks offset of the next message (#10831)

* Fix ack rc when delayed ack asks offset of the next message #7011

Signed-off-by: Daniel Kec <[email protected]>

Author: danielkec

tests/integration/jms/src/test/java/io/helidon/messaging/connectors/jms/AckMpTest.java

@@ -19,6 +19,8 @@
 import java.lang.annotation.Annotation;
 import java.time.Duration;
 import java.util.List;
+import java.util.concurrent.CompletableFuture;
+import java.util.concurrent.CompletionStage;
 
 import io.helidon.messaging.connectors.mock.MockConnector;
 import io.helidon.messaging.connectors.mock.TestConnector;
@@ -83,15 +85,18 @@ public class AckMpTest extends AbstractMPTest {
     @Incoming("test-channel-ack-1")
     @Outgoing("mock-conn-channel")
     @Acknowledgment(Acknowledgment.Strategy.MANUAL)
-    public Message<String> channelAck(Message<String> msg) {
+    public CompletionStage<Message<String>> channelAck(Message<String> msg) {
         LOGGER.log(DEBUG, () -> String.format("Received %s", msg.getPayload()));
         if (msg.getPayload().startsWith("NO_ACK")) {
             LOGGER.log(DEBUG, () -> String.format("NOT Acked %s", msg.getPayload()));
+            return CompletableFuture.completedStage(msg);
         } else {
             LOGGER.log(DEBUG, () -> String.format("Acked %s", msg.getPayload()));
-            msg.ack();
+            return msg.ack().thenApply(unused -> {
+                LOGGER.log(DEBUG, () -> String.format("Ack of %s confirmed", msg.getPayload()));
+                return msg;
+            });
         }
-        return msg;
     }
 
     @Test

tests/integration/jms/src/test/resources/logging.properties

@@ -1,5 +1,5 @@
 #
-# Copyright (c) 2020, 2023 Oracle and/or its affiliates.
+# Copyright (c) 2020, 2025 Oracle and/or its affiliates.
 #
 # Licensed under the Apache License, Version 2.0 (the "License");
 # you may not use this file except in compliance with the License.
@@ -19,6 +19,6 @@ handlers=io.helidon.logging.jul.HelidonConsoleHandler
 java.util.logging.SimpleFormatter.format=%1$tY.%1$tm.%1$td %1$tH:%1$tM:%1$tS %4$s %3$s !thread!: %5$s%6$s%n
 
 #All log level details
-.level=SEVERE
-io.helidon.messaging.level=INFO
+.level=WARNING
+io.helidon.messaging.connectors.jms.AckMpTest.level=FINE
 io.helidon.microprofile.level=INFO