diff --git a/tests/stress-tests/src/test/java/org/apache/activemq/artemis/tests/stress/paging/PageCursorStressTest.java b/tests/stress-tests/src/test/java/org/apache/activemq/artemis/tests/stress/paging/PageCursorStressTest.java index 48ab45d60e..ea79dd2589 100644 --- a/tests/stress-tests/src/test/java/org/apache/activemq/artemis/tests/stress/paging/PageCursorStressTest.java +++ b/tests/stress-tests/src/test/java/org/apache/activemq/artemis/tests/stress/paging/PageCursorStressTest.java @@ -296,7 +296,7 @@ public class PageCursorStressTest extends ActiveMQTestBase { server.start(); cursor = this.server.getPagingManager().getPageStore(ADDRESS).getCursorProvider().getSubscription(queue.getID()); - iterator = cursor.iterator(); + iterator = cursor.iterator(true); for (int i = 10; i <= 20; i++) { PagedReference msg = iterator.next(); @@ -355,7 +355,7 @@ public class PageCursorStressTest extends ActiveMQTestBase { cursor = this.server.getPagingManager().getPageStore(ADDRESS).getCursorProvider().getSubscription(queue.getID()); tx = new TransactionImpl(server.getStorageManager(), 60 * 1000); - iterator = cursor.iterator(); + iterator = cursor.iterator(true); for (int i = 10; i <= 20; i++) { PagedReference msg = iterator.next();