ARTEMIS-3464 Fixing PageAckScanTest

rh-messaging · Sep 11, 2021 · 5dbbc98 · 5dbbc98
1 parent 354fa5b
commit 5dbbc98
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/...s/src/test/java/org/apache/activemq/artemis/tests/integration/paging/PageAckScanTest.java b/...s/src/test/java/org/apache/activemq/artemis/tests/integration/paging/PageAckScanTest.java
@@ -139,7 +139,9 @@ public void testScan(String protocol, int numberOfMessages, int numberOfMessageS
       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());