Added an extra isShutdown() failsafe check when detecting if the
checkpoint thread should start
This commit is contained in:
Christopher L. Shannon (cshannon) 2016-05-09 19:34:10 +00:00
parent 100c5e0b59
commit 91213010b3
1 changed files with 1 additions and 1 deletions

View File

@ -354,7 +354,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