From 8fbda369a8967d9d66100b1b0a9d94b35c458da5 Mon Sep 17 00:00:00 2001 From: Mahmoud Ben Hassine Date: Mon, 9 Jun 2025 13:11:06 +0200 Subject: [PATCH] Remove usage of ListableJobLocator in TaskExecutorJobOperator --- .../batch/core/launch/support/SimpleJobOperator.java | 8 ++++---- .../core/launch/support/TaskExecutorJobOperator.java | 7 +++---- 2 files changed, 7 insertions(+), 8 deletions(-) diff --git a/spring-batch-core/src/main/java/org/springframework/batch/core/launch/support/SimpleJobOperator.java b/spring-batch-core/src/main/java/org/springframework/batch/core/launch/support/SimpleJobOperator.java index 9fe39de90..c43414239 100644 --- a/spring-batch-core/src/main/java/org/springframework/batch/core/launch/support/SimpleJobOperator.java +++ b/spring-batch-core/src/main/java/org/springframework/batch/core/launch/support/SimpleJobOperator.java @@ -90,7 +90,7 @@ public class SimpleJobOperator extends TaskExecutorJobLauncher implements JobOpe private static final String ILLEGAL_STATE_MSG = "Illegal state (only happens on a race condition): " + "%s with name=%s and parameters=%s"; - protected ListableJobLocator jobRegistry; + protected JobRegistry jobRegistry; protected JobParametersConverter jobParametersConverter = new DefaultJobParametersConverter(); @@ -117,10 +117,10 @@ public class SimpleJobOperator extends TaskExecutorJobLauncher implements JobOpe } /** - * Public setter for the {@link ListableJobLocator}. - * @param jobRegistry the {@link ListableJobLocator} to set + * Public setter for the {@link JobRegistry}. + * @param jobRegistry the {@link JobRegistry} to set */ - public void setJobRegistry(ListableJobLocator jobRegistry) { + public void setJobRegistry(JobRegistry jobRegistry) { this.jobRegistry = jobRegistry; } diff --git a/spring-batch-core/src/main/java/org/springframework/batch/core/launch/support/TaskExecutorJobOperator.java b/spring-batch-core/src/main/java/org/springframework/batch/core/launch/support/TaskExecutorJobOperator.java index 5198b3142..00011cb8b 100644 --- a/spring-batch-core/src/main/java/org/springframework/batch/core/launch/support/TaskExecutorJobOperator.java +++ b/spring-batch-core/src/main/java/org/springframework/batch/core/launch/support/TaskExecutorJobOperator.java @@ -16,7 +16,6 @@ package org.springframework.batch.core.launch.support; import org.springframework.batch.core.configuration.JobRegistry; -import org.springframework.batch.core.configuration.ListableJobLocator; import org.springframework.batch.core.launch.JobOperator; import org.springframework.batch.core.repository.JobRepository; @@ -43,11 +42,11 @@ import org.springframework.batch.core.repository.JobRepository; public class TaskExecutorJobOperator extends SimpleJobOperator { /** - * Public setter for the {@link ListableJobLocator}. - * @param jobRegistry the {@link ListableJobLocator} to set + * Public setter for the {@link JobRegistry}. + * @param jobRegistry the {@link JobRegistry} to set */ @Override - public void setJobRegistry(ListableJobLocator jobRegistry) { + public void setJobRegistry(JobRegistry jobRegistry) { this.jobRegistry = jobRegistry; }