commit | 5d76bcbcb87f14d4f718c891f8cc11aebf8198df | [log] [tgz] |
---|---|---|
author | Clebert Suconic <clebertsuconic@apache.org> | Thu Dec 05 16:52:58 2019 -0500 |
committer | Clebert Suconic <clebertsuconic@apache.org> | Thu Dec 05 16:52:58 2019 -0500 |
tree | 1421dca0b37d99cc3ce4c6fbac0d1e7f9ae535f3 | |
parent | d2215aa7e35d98cf8cb34bb2dd68ebc6cc9125f1 [diff] | |
parent | 9ce8cad970a6fcc2b7e186168abda2c0de8df767 [diff] |
This closes #2902
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 @@ pg.open(); List<PagedMessage> pgMessages = pg.read(storageManager); + pg.close(false, false); Map<Long, AtomicInteger> countsPerQueueOnPage = new HashMap<>(); Map<Long, AtomicLong> sizePerQueueOnPage = new HashMap<>();