diff --git a/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/MessageDatabase.java b/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/MessageDatabase.java index b1f83cf615..85e25d0bea 100644 --- a/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/MessageDatabase.java +++ b/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/MessageDatabase.java @@ -446,8 +446,9 @@ public abstract class MessageDatabase extends ServiceSupport implements BrokerSe checkpointThread.join(); } } - //clear the cache on shutdown of the store + //clear the cache and journalSize on shutdown of the store storeCache.clear(); + journalSize.set(0); } }