Skip to content

Commit f4b4d62

Browse files
committed
Added auto-migration for jobs and schedules
1 parent 681ce85 commit f4b4d62

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

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

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

115-
switch (config.get("schedule.driver")) {
115+
switch (config.get("scheduler.driver")) {
116116
case "DATABASE":
117117
Repo.get(SQLJobModel.class).autoMigrate();
118118
Repo.get(SQLScheduledTaskModel.class).autoMigrate();
119-
jobQueue = new SQLJobQueue(sql, config.get("schedule.jobs.name", "default"));
120-
schedule = new SQLSchedule(sql, config.get("schedule.jobs.name", "default"));
119+
jobQueue = new SQLJobQueue(sql, config.get("scheduler.jobs.name", "default"));
120+
schedule = new SQLSchedule(sql, config.get("scheduler.jobs.name", "default"));
121121
break;
122122
case "REDIS":
123123
jobQueue = new RedisJobQueue(new Jedis(config.get("redis.host", "localhost"), config.getInt("redis.port", 6379)), config.get("schedule.jobs.name", "default"));

0 commit comments

Comments
 (0)