activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From nigrofr...@apache.org
Subject [activemq-artemis] branch master updated: NO-JIRA Fix PageCursorStressTest with hole on ack
Date Mon, 04 Jan 2021 16:52:23 GMT
This is an automated email from the ASF dual-hosted git repository.

nigrofranz pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git


The following commit(s) were added to refs/heads/master by this push:
     new 52e7c13  NO-JIRA Fix PageCursorStressTest with hole on ack
     new 620e01b  This closes #3395
52e7c13 is described below

commit 52e7c13207b0ed7b66fa2326fc8b75ec903db940
Author: Domenico Francesco Bruscino <brusdev@apache.org>
AuthorDate: Mon Jan 4 17:46:33 2021 +0100

    NO-JIRA Fix PageCursorStressTest with hole on ack
    
    Use a browsing cursor to get depaged messages
---
 .../activemq/artemis/tests/stress/paging/PageCursorStressTest.java    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

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 48ab45d..ea79dd2 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();


Mime
View raw message