Replace usage of JobExplorer with JobRepository in SystemCommandTasklet

Resolves #4927

Author: fmbenhassine

spring-batch-core/src/main/java/org/springframework/batch/core/step/tasklet/SystemCommandTasklet.java

@@ -25,10 +25,10 @@
 import org.springframework.batch.core.ExitStatus;
 import org.springframework.batch.core.job.JobExecution;
 import org.springframework.batch.core.job.JobInterruptedException;
+import org.springframework.batch.core.repository.JobRepository;
 import org.springframework.batch.core.step.StepContribution;
 import org.springframework.batch.core.step.StepExecution;
 import org.springframework.batch.core.listener.StepExecutionListener;
-import org.springframework.batch.core.repository.explore.JobExplorer;
 import org.springframework.batch.core.scope.context.ChunkContext;
 import org.springframework.batch.repeat.RepeatStatus;
 import org.springframework.beans.factory.InitializingBean;
@@ -88,7 +88,7 @@ public class SystemCommandTasklet implements StepExecutionListener, StoppableTas
 
 	private volatile boolean stopped = false;
 
-	private JobExplorer jobExplorer;
+	private JobRepository jobRepository;
 
 	private boolean stoppable = false;
 
@@ -113,7 +113,7 @@ public RepeatStatus execute(StepContribution contribution, ChunkContext chunkCon
 			Thread.sleep(checkInterval);// moved to the end of the logic
 
 			if (stoppable) {
-				JobExecution jobExecution = jobExplorer
+				JobExecution jobExecution = jobRepository
 					.getJobExecution(chunkContext.getStepContext().getStepExecution().getJobExecutionId());
 
 				if (jobExecution.isStopping()) {
@@ -201,11 +201,11 @@ public void afterPropertiesSet() throws Exception {
 		Assert.state(systemProcessExitCodeMapper != null, "SystemProcessExitCodeMapper must be set");
 		Assert.state(timeout > 0, "timeout value must be greater than zero");
 		Assert.state(taskExecutor != null, "taskExecutor is required");
-		stoppable = jobExplorer != null;
+		stoppable = jobRepository != null;
 	}
 
-	public void setJobExplorer(JobExplorer jobExplorer) {
-		this.jobExplorer = jobExplorer;
+	public void setJobRepository(JobRepository jobRepository) {
+		this.jobRepository = jobRepository;
 	}
 
 	/**

spring-batch-core/src/test/java/org/springframework/batch/core/step/tasklet/SystemCommandTaskletIntegrationTests.java

@@ -30,9 +30,9 @@
 import org.springframework.batch.core.job.JobInstance;
 import org.springframework.batch.core.job.JobInterruptedException;
 import org.springframework.batch.core.job.parameters.JobParameters;
+import org.springframework.batch.core.repository.JobRepository;
 import org.springframework.batch.core.step.StepContribution;
 import org.springframework.batch.core.step.StepExecution;
-import org.springframework.batch.core.repository.explore.JobExplorer;
 import org.springframework.batch.core.scope.context.ChunkContext;
 import org.springframework.batch.core.scope.context.StepContext;
 import org.springframework.batch.repeat.RepeatStatus;
@@ -61,7 +61,7 @@ class SystemCommandTaskletIntegrationTests {
 			new JobExecution(new JobInstance(1L, "systemCommandJob"), 1L, new JobParameters()));
 
 	@Mock
-	private JobExplorer jobExplorer;
+	private JobRepository jobRepository;
 
 	@BeforeEach
 	void setUp() throws Exception {
@@ -247,14 +247,14 @@ void testWorkingDirectory() throws Exception {
 	@Test
 	void testStopped() throws Exception {
 		initializeTasklet();
-		tasklet.setJobExplorer(jobExplorer);
+		tasklet.setJobRepository(jobRepository);
 		tasklet.afterPropertiesSet();
 		tasklet.beforeStep(stepExecution);
 
 		JobExecution stoppedJobExecution = new JobExecution(stepExecution.getJobExecution());
 		stoppedJobExecution.setStatus(BatchStatus.STOPPING);
 
-		when(jobExplorer.getJobExecution(1L)).thenReturn(stepExecution.getJobExecution(),
+		when(jobRepository.getJobExecution(1L)).thenReturn(stepExecution.getJobExecution(),
 				stepExecution.getJobExecution(), stoppedJobExecution);
 
 		String[] command = isRunningOnWindows() ? new String[] { "ping", "127.0.0.1", "-n", "5" }