Repository: activemq Updated Branches: refs/heads/master ef129c21c -> e07809dec
NO JIRA - Clear journalSize counter The journalSize counter should be set to 0 after KahaDB is shut down. Usually, a store is not restarted again after stopping, but if it ever was the value would be wrong since it wasn't reset back to 0. Project: http://git-wip-us.apache.org/repos/asf/activemq/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/e07809de Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/e07809de Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/e07809de Branch: refs/heads/master Commit: e07809dec603832a45d5d3377b4578caee27ed49 Parents: ef129c2 Author: Christopher L. Shannon (cshannon) <christopher.l.shan...@gmail.com> Authored: Tue Nov 24 17:51:44 2015 +0000 Committer: Christopher L. Shannon (cshannon) <christopher.l.shan...@gmail.com> Committed: Tue Nov 24 17:53:34 2015 +0000 ---------------------------------------------------------------------- .../java/org/apache/activemq/store/kahadb/MessageDatabase.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq/blob/e07809de/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/MessageDatabase.java ---------------------------------------------------------------------- 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 b1f83cf..85e25d0 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); } }
