public static void main(String[] args) throws Exception { ServerConfigHelper.initLog4j("log4j-shell.xml"); ClassPathXmlApplicationContext ctx = Util.initContext("batch/new-context.xml","batch-file-ac01.xml"); JobLauncher launch = ctx.getBean(JobLauncher.class); JobExplorer epl=ctx.getBean(JobExplorer.class); JobRegistry reg =ctx.getBean(JobRegistry.class); JobOperator jop=ctx.getBean(JobOperator.class); System.out.println(epl.getJobNames()+" "+reg.getJobNames()+" "+jop.toString()); for(String bn: ctx.getBeanFactory().getBeanDefinitionNames()) { System.out.println(bn); } ctx.close(); }
public static void main(String[] args) throws JobExecutionAlreadyRunningException, JobRestartException, JobInstanceAlreadyCompleteException, JobParametersInvalidException, DuplicateJobException { ConfigurableApplicationContext ctx = SpringApplication.run(Application.class, args); Job simpleJob = ctx.getBean("simpleJob", Job.class); JobRegistry jobRegistry = ctx.getBean("jobRegistry", JobRegistry.class); jobRegistry.register(new ReferenceJobFactory(simpleJob)); //JobRepository jobRepository = ctx.getBean("jobRepository", JobRepository.class); //JobInstance jobInstance = jobRepository.createJobInstance("simpleJob", new JobParameters()); // JobParameters jobParameters = ctx.getBean("basicParameters", JobParameters.class); // //JobRegistry jobRegistry = ctx.getBean("mapJobRegistry", JobRegistry.class); // jobRegistry.register(); // jobLauncher.run(job, jobParameters); }
public JobServiceImpl(JobExplorer jobExplorer, JobOperator jobOperator, JobLauncher jobLauncher, JobRegistry jobRegistry, JobRepository jobRepository) { this.jobExplorer = jobExplorer; this.jobOperator = jobOperator; this.jobLauncher = jobLauncher; this.jobRegistry = jobRegistry; this.jobRepository = jobRepository; }
@Bean public JobService jobService(JobOperator batchJobOperator, JobRegistry batchJobRegistry, JobExplorer jobExplorer, JobLauncher jobLauncher, JobRepository jobRepository) throws Exception { return new JobServiceImpl(jobExplorer, batchJobOperator, jobLauncher, batchJobRegistry, jobRepository); }
@Bean @ConditionalOnMissingBean(JobService.class) public JobService jobService(JobOperator batchJobOperator, JobRegistry batchJobRegistry, JobExplorer jobExplorer, JobLauncher jobLauncher, JobRepository jobRepository) throws Exception { return new JobServiceImpl(jobExplorer, batchJobOperator, jobLauncher, batchJobRegistry, jobRepository); }
@Bean public AutomaticJobRegistrar jobRegistrar(JobRegistry jobRegistry) throws Exception { AutomaticJobRegistrar registrar = new AutomaticJobRegistrar(); registrar.setJobLoader(new DefaultJobLoader(jobRegistry)); for (ApplicationContextFactory factory : applicationContext.getBeansOfType(ApplicationContextFactory.class).values()) { registrar.addApplicationContextFactory(factory); } return registrar; }
@Test public void testServletConfiguration() throws Exception { ClassPathXmlApplicationContext parent = new ClassPathXmlApplicationContext( "classpath:/org/springframework/batch/admin/web/resources/webapp-config.xml"); ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext( new String[] { "classpath:/org/springframework/batch/admin/web/resources/servlet-config.xml" }, parent); assertTrue(context.containsBean("jobRepository")); String[] beanNames = BeanFactoryUtils.beanNamesForTypeIncludingAncestors(context.getBeanFactory(), JobController.class); assertEquals(1, beanNames.length); Job job = context.getBean(JobRegistry.class).getJob("job1"); final JobExecution jobExecution = parent.getBean(JobLauncher.class).run(job, new JobParametersBuilder().addString("fail", "false").toJobParameters()); new DirectPoller<BatchStatus>(100).poll(new Callable<BatchStatus>() { public BatchStatus call() throws Exception { BatchStatus status = jobExecution.getStatus(); if (status.isLessThan(BatchStatus.STOPPED) && status!=BatchStatus.COMPLETED) { return null; } return status; } }).get(2000, TimeUnit.MILLISECONDS); context.close(); parent.close(); assertEquals(BatchStatus.COMPLETED, jobExecution.getStatus()); }
public static void main(String[] args) { try { ServerConfigHelper.initConfig(); ServerConfigHelper.initLog4j("log4j-debug.xml"); ClassPathXmlApplicationContext ctx = Util.initContext("batch/new-context.xml"); JobLauncher launch = ctx.getBean(JobLauncher.class); JobExplorer epl=ctx.getBean(JobExplorer.class); JobRegistry reg =ctx.getBean(JobRegistry.class); JobOperator jop=ctx.getBean(JobOperator.class); ClassPathXmlApplicationContext ctx2 = Util.initContext(false,"batch/job-context.xml","batch-file-prod.xml"); ctx2.setParent(ctx); ctx2.refresh(); Job job = ctx2.getBean(Job.class); JobParametersBuilder build = new JobParametersBuilder(); build.addLong("Id", System.currentTimeMillis()); JobExecution exec= launch.run(job,build.toJobParameters()); System.out.println(reg.getJobNames()); Thread.sleep(Long.MAX_VALUE); } catch (Exception e) { e.printStackTrace(); } }
public BatchController(final JobRegistry jobRegistry, final JobExplorer jobExplorer, final BatchOperator batchOperator, final JobParameterInfoRegistry parameterInfos) { this.jobRegistry = jobRegistry; this.jobExplorer = jobExplorer; this.batchOperator = batchOperator; this.parameterInfos = parameterInfos; }
@Bean public JobRegistry jobRegistry() { return new MapJobRegistry() { @Override public Set<String> getJobNames() { return new TreeSet<>(super.getJobNames()); } }; }
public JobOperationsController(JobOperator jobOperator, JobExplorer jobExplorer, JobRegistry jobRegistry, JobRepository jobRepository, JobLauncher jobLauncher, JsrJobOperator jsrJobOperator) { super(); this.jobOperator = jobOperator; this.jobExplorer = jobExplorer; this.jobRegistry = jobRegistry; this.jobRepository = jobRepository; this.jobLauncher = jobLauncher; this.jsrJobOperator = jsrJobOperator; }
public MyOwnJobService(JobExplorer jobExplorer, JobOperator jobOperator, JobLauncher jobLauncher, JobRegistry jobRegistry, JobRepository jobRepository) { super(jobExplorer, jobOperator, jobLauncher, jobRegistry, jobRepository); }
@Bean public JobService jobService(JobOperator batchJobOperator, JobRegistry batchJobRegistry, JobExplorer jobExplorer, JobLauncher jobLauncher, JobRepository jobRepository) throws Exception { return new MyOwnJobService(jobExplorer, batchJobOperator, jobLauncher, batchJobRegistry, jobRepository); }
@Bean public JobRegistry jobRegistry() { return new MapJobRegistry(); }
public JobRegistry getJobRegistry() { return jobRegistry; }
public void setJobRegistry(JobRegistry jobRegistry) { this.jobRegistry = jobRegistry; }
@Autowired(required = false) public void setJobRegistry(JobRegistry jobRegistry) { this.jobRegistry = jobRegistry; }
public JobRegistry jobRegistry() { return jobRegistry; }
public JobLauncherController(JobLauncher jobLauncher, JobRegistry jobRegistry) { this.jobLauncher = jobLauncher; this.jobRegistry = jobRegistry; }