Skip to content

Commit a646b78

Browse files
committed
Fixed Nullpointerexception
1 parent f4b4d62 commit a646b78

File tree

1 file changed

+3
-5
lines changed

1 file changed

+3
-5
lines changed

src/main/java/org/javawebstack/framework/WebApplication.java

Lines changed: 3 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -112,6 +112,9 @@ public WebApplication() {
112112
setupInjection(injector);
113113
modules.forEach(m -> m.setupInjection(this, injector));
114114

115+
jobQueue = new LocalJobQueue();
116+
schedule = new LocalSchedule();
117+
115118
switch (config.get("scheduler.driver")) {
116119
case "DATABASE":
117120
Repo.get(SQLJobModel.class).autoMigrate();
@@ -123,11 +126,6 @@ public WebApplication() {
123126
jobQueue = new RedisJobQueue(new Jedis(config.get("redis.host", "localhost"), config.getInt("redis.port", 6379)), config.get("schedule.jobs.name", "default"));
124127
schedule = new RedisSchedule(new Jedis(config.get("redis.host", "localhost"), config.getInt("redis.port", 6379)), config.get("schedule.jobs.name", "default"));
125128
break;
126-
case "LOCAL":
127-
default:
128-
jobQueue = new LocalJobQueue();
129-
schedule = new LocalSchedule();
130-
break;
131129
}
132130

133131

0 commit comments

Comments
 (0)