wangwei 7 年之前
父節點
當前提交
f0b647fdac

+ 6 - 2
examcloud-task-starter/src/main/java/cn/com/qmth/examcloud/task/starter/TaskApp.java

@@ -29,7 +29,8 @@ import cn.com.qmth.examcloud.commons.base.logging.SLF4JImpl;
 import cn.com.qmth.examcloud.commons.web.redis.RedisClient;
 import cn.com.qmth.examcloud.commons.web.redis.RedisClientImpl;
 import cn.com.qmth.examcloud.commons.web.support.CustomResponseErrorHandler;
-import cn.com.qmth.examcloud.task.starter.config.JobsInitializationListener;
+import cn.com.qmth.examcloud.commons.web.support.SpringContextHolder;
+import cn.com.qmth.examcloud.task.starter.config.JobsStartup;
 
 @SpringBootApplication(scanBasePackages = {"cn.com.qmth"})
 @EnableJpaRepositories(basePackages = {"cn.com.qmth"})
@@ -48,8 +49,11 @@ public class TaskApp {
 		}
 
 		SpringApplication application = new SpringApplication(TaskApp.class);
-		application.addListeners(new JobsInitializationListener());
 		application.run(args);
+
+		JobsStartup jobsInitialization = SpringContextHolder
+				.getBean(JobsStartup.class);
+		jobsInitialization.start();
 	}
 
 	@Bean

+ 2 - 2
examcloud-task-starter/src/main/java/cn/com/qmth/examcloud/task/starter/config/JobsInitialization.java → examcloud-task-starter/src/main/java/cn/com/qmth/examcloud/task/starter/config/JobsStartup.java

@@ -11,7 +11,7 @@ import cn.com.qmth.examcloud.task.dao.ScheduleJobRepo;
 import cn.com.qmth.examcloud.task.dao.entity.ScheduleJobEntity;
 
 @Component
-public class JobsInitialization {
+public class JobsStartup {
 
 	@Autowired
 	private ScheduleJobRepo scheduleJobEntityRepo;
@@ -19,7 +19,7 @@ public class JobsInitialization {
 	@Autowired
 	private QuartzManager quartzManager;
 
-	public void init() {
+	public void start() {
 		List<ScheduleJobEntity> jobEntityList = scheduleJobEntityRepo.findAll();
 
 		for (ScheduleJobEntity jobEntity : jobEntityList) {