Apache/activemq
1
0
Fork 0
mirror of https://github.com/apache/activemq.git synced 2025-02-16 23:16:52 +00:00
Code Issues Packages Projects Releases Wiki Activity

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

Browse Source 
Added an extra isShutdown() failsafe check when detecting if the
checkpoint thread should start

(cherry picked from commit 91213010b30d426095c16d3fa8d5fa2cafaf05e5)
This commit is contained in:
Christopher L. Shannon (cshannon) 2016-05-09 19:34:10 +00:00
parent cd68c42b90
commit 0ba9f9340f
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/MessageDatabase.java
View File

@ -352,7 +352,7 @@ public abstract class MessageDatabase extends ServiceSupport implements BrokerSe
return;
}
synchronized (schedulerLock) {
if (scheduler == null) {
if (scheduler == null || scheduler.isShutdown()) {
scheduler = Executors.newSingleThreadScheduledExecutor(new ThreadFactory() {
@Override