From 5dbbc98a6258d07a9a875bb0f6da10229c8a1bcc Mon Sep 17 00:00:00 2001
From: Clebert Suconic <clebertsuconic@apache.org>
Date: Fri, 10 Sep 2021 21:39:31 -0400
Subject: [PATCH] ARTEMIS-3464 Fixing PageAckScanTest

---
 .../artemis/tests/integration/paging/PageAckScanTest.java     | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/paging/PageAckScanTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/paging/PageAckScanTest.java
index cf36a84f7e..2d3abc89e3 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/paging/PageAckScanTest.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/paging/PageAckScanTest.java
@@ -139,7 +139,9 @@ public class PageAckScanTest extends ActiveMQTestBase {
       subscription.addScanAck(() -> false, new CompareI(11), done, notFound);
       subscription.addScanAck(() -> false, new CompareI(99), done, notFound);
       subscription.addScanAck(() -> false, new CompareI(-30), done, notFound);
-      subscription.addScanAck(() -> true, new CompareI(333), retried::incrementAndGet, notFound);
+      subscription.addScanAck(() -> {
+         retried.incrementAndGet();
+         return true;}, new CompareI(333), done, notFound);
       subscription.performScanAck();
       Assert.assertTrue(latch.await(5, TimeUnit.MINUTES));
       Assert.assertEquals(2, errors.get());