|
|
|
@ -22,7 +22,7 @@ import org.springframework.batch.core.configuration.annotation.BatchConfigurer;
|
|
|
|
|
import org.springframework.batch.core.explore.JobExplorer;
|
|
|
|
|
import org.springframework.batch.core.explore.support.JobExplorerFactoryBean;
|
|
|
|
|
import org.springframework.batch.core.launch.JobLauncher;
|
|
|
|
|
import org.springframework.batch.core.launch.support.SimpleJobLauncher;
|
|
|
|
|
import org.springframework.batch.core.launch.support.TaskExecutorJobLauncher;
|
|
|
|
|
import org.springframework.batch.core.repository.JobRepository;
|
|
|
|
|
import org.springframework.batch.core.repository.support.JobRepositoryFactoryBean;
|
|
|
|
|
import org.springframework.beans.factory.InitializingBean;
|
|
|
|
@ -117,8 +117,9 @@ public class BasicBatchConfigurer implements BatchConfigurer, InitializingBean {
|
|
|
|
|
return factory.getObject();
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@SuppressWarnings({ "deprecation", "removal" })
|
|
|
|
|
protected JobLauncher createJobLauncher() throws Exception {
|
|
|
|
|
SimpleJobLauncher jobLauncher = new SimpleJobLauncher();
|
|
|
|
|
TaskExecutorJobLauncher jobLauncher = new TaskExecutorJobLauncher();
|
|
|
|
|
jobLauncher.setJobRepository(getJobRepository());
|
|
|
|
|
jobLauncher.afterPropertiesSet();
|
|
|
|
|
return jobLauncher;
|
|
|
|
|