Commit 8fbda36

committed

Remove usage of ListableJobLocator in TaskExecutorJobOperator

1 parent 90f7398 commit 8fbda36Copy full SHA for 8fbda36

File tree

-8

lines changed

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

-8

lines changed

Lines changed: 4 additions & 4 deletions

Original file line number	Diff line number	Diff line change
`@@ -90,7 +90,7 @@ public class SimpleJobOperator extends TaskExecutorJobLauncher implements JobOpe`
`90`	`90`	`private static final String ILLEGAL_STATE_MSG = "Illegal state (only happens on a race condition): "`
`91`	`91`	`+ "%s with name=%s and parameters=%s";`
`92`	`92`
`93`		`- protected ListableJobLocator jobRegistry;`
	`93`	`+ protected JobRegistry jobRegistry;`
`94`	`94`
`95`	`95`	`protected JobParametersConverter jobParametersConverter = new DefaultJobParametersConverter();`
`96`	`96`
`@@ -117,10 +117,10 @@ public void setJobParametersConverter(JobParametersConverter jobParametersConver`
`117`	`117`	`}`
`118`	`118`
`119`	`119`	`/**`
`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`
`122`	`122`	`*/`
`123`		`- public void setJobRegistry(ListableJobLocator jobRegistry) {`
	`123`	`+ public void setJobRegistry(JobRegistry jobRegistry) {`
`124`	`124`	`this.jobRegistry = jobRegistry;`
`125`	`125`	`}`
`126`	`126`

Lines changed: 3 additions & 4 deletions

Original file line number	Diff line number	Diff line change
`@@ -16,7 +16,6 @@`
`16`	`16`	`package org.springframework.batch.core.launch.support;`
`17`	`17`
`18`	`18`	`import org.springframework.batch.core.configuration.JobRegistry;`
`19`		`-import org.springframework.batch.core.configuration.ListableJobLocator;`
`20`	`19`	`import org.springframework.batch.core.launch.JobOperator;`
`21`	`20`	`import org.springframework.batch.core.repository.JobRepository;`
`22`	`21`
`@@ -43,11 +42,11 @@`
`43`	`42`	`public class TaskExecutorJobOperator extends SimpleJobOperator {`
`44`	`43`
`45`	`44`	`/**`
`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`
`48`	`47`	`*/`
`49`	`48`	`@Override`
`50`		`- public void setJobRegistry(ListableJobLocator jobRegistry) {`
	`49`	`+ public void setJobRegistry(JobRegistry jobRegistry) {`
`51`	`50`	`this.jobRegistry = jobRegistry;`
`52`	`51`	`}`
`53`	`52`

Comments

(0)