activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From clebertsuco...@apache.org
Subject [activemq-artemis] branch master updated: NO-JIRA close page after recovering page counter
Date Thu, 05 Dec 2019 21:53:08 GMT
This is an automated email from the ASF dual-hosted git repository.

clebertsuconic 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 9ce8cad  NO-JIRA close page after recovering page counter
     new 5d76bcb  This closes #2902
9ce8cad is described below

commit 9ce8cad970a6fcc2b7e186168abda2c0de8df767
Author: Wei Yang <wy96fyw@gmail.com>
AuthorDate: Thu Nov 28 15:01:53 2019 +0800

    NO-JIRA close page after recovering page counter
---
 .../activemq/artemis/core/server/impl/PostOfficeJournalLoader.java       | 1 +
 1 file changed, 1 insertion(+)

diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/PostOfficeJournalLoader.java
b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/PostOfficeJournalLoader.java
index 60f3528..c18835c 100644
--- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/PostOfficeJournalLoader.java
+++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/PostOfficeJournalLoader.java
@@ -378,6 +378,7 @@ public class PostOfficeJournalLoader implements JournalLoader {
                pg.open();
 
                List<PagedMessage> pgMessages = pg.read(storageManager);
+               pg.close(false, false);
                Map<Long, AtomicInteger> countsPerQueueOnPage = new HashMap<>();
                Map<Long, AtomicLong> sizePerQueueOnPage = new HashMap<>();
 


Mime
View raw message