From af63b1a256dc5ed166943e910f2b9f8a507f0ddb Mon Sep 17 00:00:00 2001 From: eastargh Date: Thu, 18 Jun 2026 11:05:26 +0900 Subject: [PATCH] =?UTF-8?q?=EB=B0=B0=EC=B9=98=EC=9E=A1=20=EA=B8=B0?= =?UTF-8?q?=EB=B3=B8=EC=97=90=EC=84=9C=20=ED=81=B4=EB=9F=AC=EC=8A=A4?= =?UTF-8?q?=ED=84=B0=EB=A1=9C=20=EC=88=98=EC=A0=95=EC=8B=9C=20next=20fire?= =?UTF-8?q?=20time=20=3Dnull=EC=9D=B8=20=EB=B2=84=EA=B7=B8=20=EC=88=98?= =?UTF-8?q?=EC=A0=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../scheduler/ClusteredSchedulerConfig.java | 2 +- .../common/scheduler/EMSSchedulerImpl.java | 20 ++----------------- 2 files changed, 3 insertions(+), 19 deletions(-) diff --git a/src/main/java/com/eactive/eai/rms/common/scheduler/ClusteredSchedulerConfig.java b/src/main/java/com/eactive/eai/rms/common/scheduler/ClusteredSchedulerConfig.java index cdfe08a..333dbd7 100644 --- a/src/main/java/com/eactive/eai/rms/common/scheduler/ClusteredSchedulerConfig.java +++ b/src/main/java/com/eactive/eai/rms/common/scheduler/ClusteredSchedulerConfig.java @@ -57,7 +57,7 @@ public class ClusteredSchedulerConfig { quartzProperties.put("org.quartz.jobStore.misfireThreshold", "60000"); quartzProperties.put("org.quartz.jobStore.class", "org.quartz.impl.jdbcjobstore.JobStoreTX"); - quartzProperties.put("org.quartz.jobStore.driverDelegateClass", "org.quartz.impl.jdbcjobstore.PostgreSQLDelegate"); + quartzProperties.put("org.quartz.jobStore.driverDelegateClass", "org.quartz.impl.jdbcjobstore.StdJDBCDelegate"); quartzProperties.put("org.quartz.jobStore.useProperties", "false"); quartzProperties.put("org.quartz.jobStore.dataSource", monitoringSchema); quartzProperties.put("org.quartz.jobStore.tablePrefix", monitoringSchema + ".QRTZ_"); diff --git a/src/main/java/com/eactive/eai/rms/common/scheduler/EMSSchedulerImpl.java b/src/main/java/com/eactive/eai/rms/common/scheduler/EMSSchedulerImpl.java index 929f5ea..d60458d 100644 --- a/src/main/java/com/eactive/eai/rms/common/scheduler/EMSSchedulerImpl.java +++ b/src/main/java/com/eactive/eai/rms/common/scheduler/EMSSchedulerImpl.java @@ -139,9 +139,6 @@ public class EMSSchedulerImpl implements EMSScheduler { Trigger existing = clusteredScheduler.getTrigger(triggerKey); JobDetail existingJob = clusteredScheduler.getJobDetail(jobKey); - log.info("[reloadClusteredJob] {} - existingTrigger={}, existingJob={}", jobId, - existing != null ? existing.getKey() : "null", - existingJob != null ? existingJob.getKey() : "null"); if (existing != null && existingJob != null) { CronTrigger newTrigger = newTrigger() @@ -150,7 +147,6 @@ public class EMSSchedulerImpl implements EMSScheduler { .build(); Date ft = clusteredScheduler.rescheduleJob(triggerKey, newTrigger); if (ft != null) { - log.info("[reloadClusteredJob] {} rescheduled at: {} cron: {}", jobId, ft, jobInfo.getCronExp()); return; } log.warn("[reloadClusteredJob] {} rescheduleJob returned null, falling back to deleteAndAddJob", jobId); @@ -159,7 +155,6 @@ public class EMSSchedulerImpl implements EMSScheduler { log.warn("[reloadClusteredJob] {} has orphaned trigger without job, unscheduling", jobId); clusteredScheduler.unscheduleJob(triggerKey); } - log.info("[reloadClusteredJob] {} calling deleteAndAddJob on clusteredScheduler", jobId); deleteAndAddJob(clusteredScheduler, jobInfo); } @@ -167,10 +162,8 @@ public class EMSSchedulerImpl implements EMSScheduler { String schedulerType = (inScheduler == clusteredScheduler) ? "clusteredScheduler" : "scheduler"; JobKey key = new JobKey(jobNm, Scheduler.DEFAULT_GROUP); JobDetail jobDetail = inScheduler.getJobDetail(key); - log.info("[deleteJob] {} from {} — found={}", jobNm, schedulerType, jobDetail != null); if (jobDetail != null) { inScheduler.deleteJob(key); - log.info("[deleteJob] {} deleted from {}", jobNm, schedulerType); } } @@ -179,12 +172,8 @@ public class EMSSchedulerImpl implements EMSScheduler { if (StringUtils.equalsIgnoreCase(info.getUseYn(), "Y") && StringUtils.equalsAnyIgnoreCase(info.getInstanceName(), "ALL", "CLUSTERED", ContainerUtil.getInstanceName())) { - String schedulerType = (inScheduler == clusteredScheduler) ? "clusteredScheduler" : "scheduler"; - log.info("[addJob] {} → {}, class={}, cron={}", info.getId(), schedulerType, info.getJobClassName(), info.getCronExp()); - @SuppressWarnings("unchecked") Class jobClass = (Class) Class.forName(info.getJobClassName()); - log.info("[addJob] {} class loaded: {}", info.getId(), jobClass.getName()); JobBuilder jobBuilder = newJob(jobClass); jobBuilder = jobBuilder.withIdentity(info.getId(), Scheduler.DEFAULT_GROUP); @@ -200,13 +189,8 @@ public class EMSSchedulerImpl implements EMSScheduler { .withSchedule(cronSchedule(info.getCronExp())) .build(); - log.info("[addJob] {} calling scheduleJob...", info.getId()); - Date ft = inScheduler.scheduleJob(job, trigger); - log.info("[addJob] {} scheduled at: {} cron: {}", job.getKey(), ft, trigger.getCronExpression()); - } else { - log.info("[addJob] {} skipped — useYn={}, instanceName={}, currentInstance={}", - info.getId(), info.getUseYn(), info.getInstanceName(), ContainerUtil.getInstanceName()); - } + inScheduler.scheduleJob(job, trigger); + } } }