activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From cshan...@apache.org
Subject activemq git commit: NO JIRA - Clear journalSize counter
Date Tue, 24 Nov 2015 18:09:56 GMT
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.shannon@gmail.com>
Authored: Tue Nov 24 17:51:44 2015 +0000
Committer: Christopher L. Shannon (cshannon) <christopher.l.shannon@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);
         }
     }
 


Mime
View raw message