private JobExecution launchImmediately(TaskExecutor taskExecutor, Job job, JobParameters jobParameters) { try { SimpleJobLauncher launcher = new SimpleJobLauncher(); launcher.setJobRepository(jobRepository); launcher.setTaskExecutor(taskExecutor); return launcher.run(job, jobParameters); } catch (JobExecutionAlreadyRunningException | JobRestartException | JobInstanceAlreadyCompleteException | JobParametersInvalidException e) { logger.error("Unexpected exception", e); throw YonaException.unexpected(e); } }
/** * @param args */ public static void main(String[] args) { ClassPathXmlApplicationContext c = new ClassPathXmlApplicationContext( "billing_job.xml"); SimpleJobLauncher launcher = new SimpleJobLauncher(); launcher.setJobRepository((JobRepository) c.getBean("jobRepository")); launcher.setTaskExecutor(new SyncTaskExecutor()); try { Map<String, JobParameter> parameters = new HashMap<String, JobParameter>(); parameters.put(RUN_MONTH_KEY, new JobParameter("2011-2")); JobExecution je = launcher.run((Job) c.getBean("billingJob"), new JobParameters(parameters)); System.out.println(je); System.out.println(je.getJobInstance()); System.out.println(je.getStepExecutions()); } catch (Exception e) { e.printStackTrace(); } }
public static void main(String[] args) { ClassPathXmlApplicationContext c = new ClassPathXmlApplicationContext( "message_job.xml"); SimpleJobLauncher launcher = new SimpleJobLauncher(); launcher.setJobRepository((JobRepository) c.getBean("jobRepository")); launcher.setTaskExecutor(new SyncTaskExecutor()); try { Map<String, JobParameter> parameters = new HashMap<String, JobParameter>(); parameters.put(RUN_MONTH_KEY, new JobParameter("2011-10")); JobExecution je = launcher.run((Job) c.getBean("messageJob"), new JobParameters(parameters)); System.out.println(je); System.out.println(je.getJobInstance()); System.out.println(je.getStepExecutions()); } catch (Exception e) { e.printStackTrace(); } }
@Override protected JobLauncher createJobLauncher() throws Exception { SimpleJobLauncher jobLauncher = new SimpleJobLauncher(); jobLauncher.setJobRepository(super.getJobRepository()); jobLauncher.setTaskExecutor(batchTaskScheduler()); jobLauncher.afterPropertiesSet(); return jobLauncher; }
@Bean public JobLauncher getJobLauncher() throws Exception { SimpleJobLauncher jobLauncher = new SimpleJobLauncher(); jobLauncher.setJobRepository(jobRepository().getObject()); jobLauncher.afterPropertiesSet(); return jobLauncher; }
private static JobLauncher createJobLauncher(JobRepository jobRepository, TaskExecutor taskExecutor) throws Exception { SimpleJobLauncher jobLauncher = new SimpleJobLauncher(); jobLauncher.setJobRepository(jobRepository); jobLauncher.setTaskExecutor(taskExecutor); jobLauncher.afterPropertiesSet(); return jobLauncher; }
@Override public JobLauncher getJobLauncher() throws Exception { SimpleJobLauncher launcher = new SimpleJobLauncher(); launcher.setJobRepository(this.jobRepository); launcher.setTaskExecutor(new SyncTaskExecutor()); return launcher; }
@Bean public SimpleJobServiceFactoryBean simpleJobServiceFactoryBean(DataSource dataSource, JobRepositoryFactoryBean repositoryFactoryBean) throws Exception { SimpleJobServiceFactoryBean factoryBean = new SimpleJobServiceFactoryBean(); factoryBean.setDataSource(dataSource); factoryBean.setJobRepository(repositoryFactoryBean.getObject()); factoryBean.setJobLocator(new MapJobRegistry()); factoryBean.setJobLauncher(new SimpleJobLauncher()); factoryBean.setDataSource(dataSource); return factoryBean; }
@Bean public SimpleJobServiceFactoryBean simpleJobServiceFactoryBean(DataSource dataSource, JobRepositoryFactoryBean repositoryFactoryBean) { SimpleJobServiceFactoryBean factoryBean = new SimpleJobServiceFactoryBean(); factoryBean.setDataSource(dataSource); try { factoryBean.setJobRepository(repositoryFactoryBean.getObject()); factoryBean.setJobLocator(new MapJobRegistry()); factoryBean.setJobLauncher(new SimpleJobLauncher()); } catch (Exception e) { throw new IllegalStateException(e); } return factoryBean; }
private JobLauncher createJobLauncher() throws Exception { final SimpleJobLauncher jobLauncher = new SimpleJobLauncher(); //async TODO jobLauncher.setTaskExecutor(taskExecutor()); jobLauncher.setJobRepository(this.jobRepository); jobLauncher.afterPropertiesSet(); return jobLauncher; }
@Override public JobLauncher getJobLauncher() { final SimpleJobLauncher launcher = (SimpleJobLauncher) super.getJobLauncher(); launcher.setTaskExecutor(batchTaskExecutor()); return launcher; }
@Before public void setUp() throws Exception { mockServer = MockRestServiceServer.createServer(restTemplate); SmtpServerStub.start(); jobParams = new JobParametersBuilder() .addLong("month", 2L) .addLong("year", 2014L).toJobParameters(); employeeGeneratorService.resetEmployees(NUMBER_OF_EMPLOYEES); runningTimeService.setMaximumTime(51); runningTimeService.setMinimumTime(50); jobLauncher = new SimpleJobLauncher(); jobLauncher.setJobRepository(jobRepository); }
/** job launcher used for executing jobs on http requests, here: for batch admin */ @Bean public JobLauncher asyncJobLauncher() throws Exception { SimpleJobLauncher jobLauncher = new SimpleJobLauncher(); jobLauncher.setJobRepository(jobRepository()); jobLauncher.setTaskExecutor(new SimpleAsyncTaskExecutor()); jobLauncher.afterPropertiesSet(); return jobLauncher; }
private JobLauncher createJobLauncher() throws Exception { SimpleJobLauncher jobLauncher = new SimpleJobLauncher(); jobLauncher.setJobRepository(jobRepository); jobLauncher.setTaskExecutor(taskExecutor); jobLauncher.afterPropertiesSet(); return jobLauncher; }
private JobLauncher createJobLauncher() throws Exception { SimpleJobLauncher jobLauncher = new SimpleJobLauncher(); jobLauncher.setJobRepository(jobRepository); jobLauncher.setTaskExecutor( new SimpleAsyncTaskExecutor()); jobLauncher.afterPropertiesSet(); return jobLauncher; }
@Bean public SimpleJobLauncher jobLauncher(JobRepository jobRepository) { SimpleJobLauncher simpleJobLauncher = new SimpleJobLauncher(); simpleJobLauncher.setJobRepository(jobRepository); return simpleJobLauncher; }
protected JobLauncher createJobLauncher() throws Exception { SimpleJobLauncher jobLauncher = new SimpleJobLauncher(); jobLauncher.setJobRepository(getJobRepository()); jobLauncher.afterPropertiesSet(); return jobLauncher; }
@Override public JobLauncher getJobLauncher() throws Exception { SimpleJobLauncher launcher = new SimpleJobLauncher(); launcher.setJobRepository(this.jobRepository); return launcher; }
private JobLauncher createJobLauncher() throws Exception { SimpleJobLauncher jobLauncher = new SimpleJobLauncher(); jobLauncher.setJobRepository(getJobRepository()); jobLauncher.afterPropertiesSet(); return jobLauncher; }
protected JobLauncher createJobLauncher() throws Exception { SimpleJobLauncher jobLauncher = new SimpleJobLauncher(); jobLauncher.setJobRepository(jobRepository); jobLauncher.afterPropertiesSet(); return jobLauncher; }