qcast3/qcast-api
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

dev #400

Merged
ysCha merged 2 commits from dev into prd-deploy 2026-02-23 09:11:32 +09:00
Conversation 0 Commits 2 Files Changed 2 +9
1 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit 711c8fcdca - Show all commits

9
src/main/java/com/interplug/qcast/batch/JobLauncherController.java
View File

@ -39,6 +39,9 @@ public class JobLauncherController {
@Value("${spring.profiles.scheduler}") @Value("${spring.profiles.scheduler}")
private String scheduler; private String scheduler;
@Value("${server.port:8080}")
private int serverPort;
/** /**
* 서버 시작 시 실행 중(STARTED)인 상태로 남은 Job들을 FAILED 처리 * 서버 시작 시 실행 중(STARTED)인 상태로 남은 Job들을 FAILED 처리
*/ */
@ -253,6 +256,12 @@ public class JobLauncherController {
* 공통 스케줄러 실행 메소드 * 공통 스케줄러 실행 메소드
*/ */
private String executeScheduledJob(String jobName) throws JobInstanceAlreadyCompleteException, JobExecutionAlreadyRunningException, JobParametersInvalidException, JobRestartException { private String executeScheduledJob(String jobName) throws JobInstanceAlreadyCompleteException, JobExecutionAlreadyRunningException, JobParametersInvalidException, JobRestartException {
// 8080 포트 인스턴스에서만 스케줄러 실행 (멀티 인스턴스 데드락 방지)
if (serverPort != 8080) {
log.debug("스케줄러는 8080 포트 인스턴스에서만 실행됩니다. 현재 포트: {}, Job: {} 스킵", serverPort, jobName);
return "Scheduler runs only on port 8080. Current port: " + serverPort;
}
Job job = jobs.get(jobName); Job job = jobs.get(jobName);
if (job == null) { if (job == null) {
log.error("Job {} not found", jobName); log.error("Job {} not found", jobName);