Giriş
Şu satırı dahil ederiz
Şu satırı dahil ederiz
import org.springframework.batch.core.repository.support.JobRepositoryFactoryBean;
JobRepository nesnesi yaratır
Şöyle yaparız
@Beanpublic JobRepository hazelCastJobRepo(DataSource dataSource,HazelcastTransactionManager hazelcastTransactionManager) {JobRepositoryFactoryBean jobRepositoryFactoryBean = new JobRepositoryFactoryBean();jobRepositoryFactoryBean.setDataSource(dataSource);jobRepositoryFactoryBean.setDatabaseType("POSTGRES");jobRepositoryFactoryBean.setTransactionManager(hazelcastTransactionManager);return jobRepositoryFactoryBean.getObject();}
Örnek
Şöyle yaparız
@Autowired
private DataSource dataSource;
@Bean
public JobRepository jobRepository() throws Exception {
  JobRepositoryFactoryBean factory = new JobRepositoryFactoryBean();
  factory.setDataSource(dataSource);
  factory.setTransactionManager(transactionManager());
  factory.afterPropertiesSet();
  return factory.getObject();
}
@Bean
public PlatformTransactionManager transactionManager() {
  return new DataSourceTransactionManager(dataSource);
}
@Bean
public JobLauncher jobLauncher() throws Exception {
  SimpleJobLauncher launcher = new SimpleJobLauncher();
  launcher.setJobRepository(jobRepository());
  launcher.setTaskExecutor(new SimpleAsyncTaskExecutor());
  launcher.afterPropertiesSet();
  return launcher;
} 
Hiç yorum yok:
Yorum Gönder