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

This closes #3395

This commit is contained in:
franz1981 2021-01-04 17:52:02 +01:00
parent c63aa9f481 52e7c13207
commit 620e01b6b5
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(); server.start();
cursor = this.server.getPagingManager().getPageStore(ADDRESS).getCursorProvider().getSubscription(queue.getID()); cursor = this.server.getPagingManager().getPageStore(ADDRESS).getCursorProvider().getSubscription(queue.getID());
iterator = cursor.iterator(); iterator = cursor.iterator(true);
for (int i = 10; i <= 20; i++) { for (int i = 10; i <= 20; i++) {
PagedReference msg = iterator.next(); PagedReference msg = iterator.next();
@ -355,7 +355,7 @@ public class PageCursorStressTest extends ActiveMQTestBase {
cursor = this.server.getPagingManager().getPageStore(ADDRESS).getCursorProvider().getSubscription(queue.getID()); cursor = this.server.getPagingManager().getPageStore(ADDRESS).getCursorProvider().getSubscription(queue.getID());
tx = new TransactionImpl(server.getStorageManager(), 60 * 1000); tx = new TransactionImpl(server.getStorageManager(), 60 * 1000);
iterator = cursor.iterator(); iterator = cursor.iterator(true);
for (int i = 10; i <= 20; i++) { for (int i = 10; i <= 20; i++) {
PagedReference msg = iterator.next(); PagedReference msg = iterator.next();