Skip to content

Commit 8fbda36

Browse files
committed
Remove usage of ListableJobLocator in TaskExecutorJobOperator
1 parent 90f7398 commit 8fbda36

File tree

2 files changed

+7
-8
lines changed

2 files changed

+7
-8
lines changed

spring-batch-core/src/main/java/org/springframework/batch/core/launch/support/SimpleJobOperator.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -90,7 +90,7 @@ public class SimpleJobOperator extends TaskExecutorJobLauncher implements JobOpe
9090
private static final String ILLEGAL_STATE_MSG = "Illegal state (only happens on a race condition): "
9191
+ "%s with name=%s and parameters=%s";
9292

93-
protected ListableJobLocator jobRegistry;
93+
protected JobRegistry jobRegistry;
9494

9595
protected JobParametersConverter jobParametersConverter = new DefaultJobParametersConverter();
9696

@@ -117,10 +117,10 @@ public void setJobParametersConverter(JobParametersConverter jobParametersConver
117117
}
118118

119119
/**
120-
* Public setter for the {@link ListableJobLocator}.
121-
* @param jobRegistry the {@link ListableJobLocator} to set
120+
* Public setter for the {@link JobRegistry}.
121+
* @param jobRegistry the {@link JobRegistry} to set
122122
*/
123-
public void setJobRegistry(ListableJobLocator jobRegistry) {
123+
public void setJobRegistry(JobRegistry jobRegistry) {
124124
this.jobRegistry = jobRegistry;
125125
}
126126

spring-batch-core/src/main/java/org/springframework/batch/core/launch/support/TaskExecutorJobOperator.java

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,6 @@
1616
package org.springframework.batch.core.launch.support;
1717

1818
import org.springframework.batch.core.configuration.JobRegistry;
19-
import org.springframework.batch.core.configuration.ListableJobLocator;
2019
import org.springframework.batch.core.launch.JobOperator;
2120
import org.springframework.batch.core.repository.JobRepository;
2221

@@ -43,11 +42,11 @@
4342
public class TaskExecutorJobOperator extends SimpleJobOperator {
4443

4544
/**
46-
* Public setter for the {@link ListableJobLocator}.
47-
* @param jobRegistry the {@link ListableJobLocator} to set
45+
* Public setter for the {@link JobRegistry}.
46+
* @param jobRegistry the {@link JobRegistry} to set
4847
*/
4948
@Override
50-
public void setJobRegistry(ListableJobLocator jobRegistry) {
49+
public void setJobRegistry(JobRegistry jobRegistry) {
5150
this.jobRegistry = jobRegistry;
5251
}
5352

0 commit comments

Comments
 (0)