This commit is contained in:
Ken Stevens 2019-12-04 21:20:09 -05:00
parent c516ab8a75
commit 676a443cf2
1 changed files with 7 additions and 1 deletions

View File

@ -76,6 +76,9 @@ public abstract class BaseHapiScheduler implements IHapiScheduler {
@Override @Override
public void start() { public void start() {
if (myScheduler == null) {
throw new ConfigurationException("Attempt to start uninitialized scheduler");
}
try { try {
ourLog.info("Starting scheduler {}", getThreadPrefix()); ourLog.info("Starting scheduler {}", getThreadPrefix());
myScheduler.start(); myScheduler.start();
@ -87,6 +90,9 @@ public abstract class BaseHapiScheduler implements IHapiScheduler {
@Override @Override
public void shutdown() { public void shutdown() {
if (myScheduler == null) {
return;
}
try { try {
myScheduler.shutdown(true); myScheduler.shutdown(true);
} catch (SchedulerException e) { } catch (SchedulerException e) {
@ -98,7 +104,7 @@ public abstract class BaseHapiScheduler implements IHapiScheduler {
@Override @Override
public boolean isStarted() { public boolean isStarted() {
try { try {
return myScheduler.isStarted(); return myScheduler != null && myScheduler.isStarted();
} catch (SchedulerException e) { } catch (SchedulerException e) {
ourLog.error("Failed to determine scheduler status", e); ourLog.error("Failed to determine scheduler status", e);
return false; return false;