배치잡 Reload시 data도 reload되도록 수정

2026-06-29 13:32:08 +09:00
parent aee02cc2a6
commit ed44183de3
1 changed files with 10 additions and 0 deletions
@@ -141,6 +141,16 @@ public class EMSSchedulerImpl implements EMSScheduler {
      JobDetail existingJob = clusteredScheduler.getJobDetail(jobKey);

      if (existing != null && existingJob != null) {
+         // JobDetail(JobData 포함) 갱신
+         @SuppressWarnings("unchecked")
+         Class<Job> jobClass = (Class<Job>) Class.forName(jobInfo.getJobClassName());
+         JobBuilder jobBuilder = newJob(jobClass).withIdentity(jobKey);
+         for (JobData jobData : jobInfo.getJobDatas()) {
+            jobBuilder.usingJobData(jobData.getId().getDataKey(), jobData.getDataValue());
+         }
+         clusteredScheduler.addJob(jobBuilder.build(), true);
+
+         // 트리거(cron) 갱신
         CronTrigger newTrigger = newTrigger()
               .withIdentity(triggerKey)
               .withSchedule(cronSchedule(jobInfo.getCronExp()))