Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

NO-JIRA Fix PageCursorStressTest with hole on ack 

Use a browsing cursor to get depaged messages
This commit is contained in:
Domenico Francesco Bruscino 2021-01-04 17:46:33 +01:00
parent c63aa9f481
commit 52e7c13207
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
tests/stress-tests/src/test/java/org/apache/activemq/artemis/tests/stress/paging/PageCursorStressTest.java
View File

@ -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();