@@ -115,20 +115,21 @@ public WebApplication() {
115115 jobQueue = new LocalJobQueue ();
116116 schedule = new LocalSchedule ();
117117
118- switch (config .get ("scheduler.driver" )) {
119- case "DATABASE" :
120- Repo .get (SQLJobModel .class ).autoMigrate ();
121- Repo .get (SQLScheduledTaskModel .class ).autoMigrate ();
122- jobQueue = new SQLJobQueue (sql , config .get ("scheduler.jobs.name" , "default" ));
123- schedule = new SQLSchedule (sql , config .get ("scheduler.jobs.name" , "default" ));
124- break ;
125- case "REDIS" :
126- jobQueue = new RedisJobQueue (new Jedis (config .get ("redis.host" , "localhost" ), config .getInt ("redis.port" , 6379 )), config .get ("schedule.jobs.name" , "default" ));
127- schedule = new RedisSchedule (new Jedis (config .get ("redis.host" , "localhost" ), config .getInt ("redis.port" , 6379 )), config .get ("schedule.jobs.name" , "default" ));
128- break ;
118+ if (config .get ("scheduler.driver" ) != null ) {
119+ switch (config .get ("scheduler.driver" )) {
120+ case "DATABASE" :
121+ Repo .get (SQLJobModel .class ).autoMigrate ();
122+ Repo .get (SQLScheduledTaskModel .class ).autoMigrate ();
123+ jobQueue = new SQLJobQueue (sql , config .get ("scheduler.jobs.name" , "default" ));
124+ schedule = new SQLSchedule (sql , config .get ("scheduler.jobs.name" , "default" ));
125+ break ;
126+ case "REDIS" :
127+ jobQueue = new RedisJobQueue (new Jedis (config .get ("redis.host" , "localhost" ), config .getInt ("redis.port" , 6379 )), config .get ("schedule.jobs.name" , "default" ));
128+ schedule = new RedisSchedule (new Jedis (config .get ("redis.host" , "localhost" ), config .getInt ("redis.port" , 6379 )), config .get ("schedule.jobs.name" , "default" ));
129+ break ;
130+ }
129131 }
130132
131-
132133 injector .setInstance (JobQueue .class , jobQueue );
133134 injector .setInstance (Schedule .class , schedule );
134135
0 commit comments