activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject activemq git commit: https://issues.apache.org/jira/browse/AMQ-6358
Date Thu, 14 Jul 2016 14:50:04 GMT
Repository: activemq
Updated Branches:
  refs/heads/master 71ee1eae1 -> 8cc5c56d5


https://issues.apache.org/jira/browse/AMQ-6358

Wait until recover is done before starting the checkpoint tasks.

Project: http://git-wip-us.apache.org/repos/asf/activemq/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/8cc5c56d
Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/8cc5c56d
Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/8cc5c56d

Branch: refs/heads/master
Commit: 8cc5c56d5ef98bbdd8f004428c4fac30abb1c39a
Parents: 71ee1ea
Author: Timothy Bish <tabish121@gmail.com>
Authored: Thu Jul 14 10:49:23 2016 -0400
Committer: Timothy Bish <tabish121@gmail.com>
Committed: Thu Jul 14 10:49:59 2016 -0400

----------------------------------------------------------------------
 .../java/org/apache/activemq/store/kahadb/MessageDatabase.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq/blob/8cc5c56d/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 cc3f676..c4d51af 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
@@ -433,8 +433,8 @@ public abstract class MessageDatabase extends ServiceSupport implements
BrokerSe
                 pageFile = null;
                 loadPageFile();
             }
-            startCheckpoint();
             recover();
+            startCheckpoint();
         }
     }
 


Mime
View raw message