You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by gt...@apache.org on 2014/12/22 13:45:28 UTC
activemq git commit: https://issues.apache.org/jira/browse/AMQ-5493 -
apply patch from pedro with thanks - prevent spurious thread start on
shutdown
Repository: activemq
Updated Branches:
refs/heads/trunk e16815ad3 -> 02d974c40
https://issues.apache.org/jira/browse/AMQ-5493 - apply patch from pedro with thanks - prevent spurious thread start on shutdown
Project: http://git-wip-us.apache.org/repos/asf/activemq/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/02d974c4
Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/02d974c4
Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/02d974c4
Branch: refs/heads/trunk
Commit: 02d974c40940969eee7d7f4f3d519bd2335093e6
Parents: e16815a
Author: gtully <ga...@gmail.com>
Authored: Mon Dec 22 12:44:41 2014 +0000
Committer: gtully <ga...@gmail.com>
Committed: Mon Dec 22 12:44:41 2014 +0000
----------------------------------------------------------------------
.../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/02d974c4/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 13e9b3c..35a59ce 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
@@ -990,7 +990,7 @@ public abstract class MessageDatabase extends ServiceSupport implements BrokerSe
after.run();
}
- if (checkpointThread != null && !checkpointThread.isAlive()) {
+ if (checkpointThread != null && !checkpointThread.isAlive() && opened.get()) {
startCheckpoint();
}
return location;