Package org.springframework.batch.core

Examples of org.springframework.batch.core.JobExecution

310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
  @RequestMapping(value = "/jobs/executions/{jobExecutionId}", method = RequestMethod.GET)
  public String detail(Model model, @PathVariable Long jobExecutionId, @ModelAttribute("date") Date date,
      Errors errors) {

    try {
      JobExecution jobExecution = jobService.getJobExecution(jobExecutionId);
      model.addAttribute(new JobExecutionInfo(jobExecution, timeZone));
      String jobName = jobExecution.getJobInstance().getJobName();
      Collection<String> stepNames = new HashSet<String>(jobService.getStepNamesForJob(jobName));
      Collection<StepExecution> stepExecutions = new ArrayList<StepExecution>(jobExecution.getStepExecutions());
      Collection<StepExecutionInfo> stepExecutionInfos = new ArrayList<StepExecutionInfo>();

      for (String name : stepNames) {
        boolean found = false;
        for (Iterator<StepExecution> iterator = stepExecutions.iterator(); iterator.hasNext();) {
View Full Code Here
350
351
352
353
354
355
356
357
358
359
360
361
362
363
  @RequestMapping(value = "/jobs/executions/{jobExecutionId}/execution-context", method = RequestMethod.GET)
  public String getExecutionContext(Model model, @PathVariable Long jobExecutionId, @ModelAttribute("date") Date date,
                    Errors errors) {
    try {
      JobExecution jobExecution = jobService.getJobExecution(jobExecutionId);
      Map<String, Object> executionMap = new HashMap<String, Object>();

      for (Map.Entry<String, Object> entry : jobExecution.getExecutionContext().entrySet()) {
        executionMap.put(entry.getKey(), entry.getValue());
      }

      model.addAttribute("jobExecutionContext", objectMapper.writeValueAsString(executionMap));
      model.addAttribute("jobExecutionId", jobExecutionId);
View Full Code Here
120
121
122
123
124
125
126
127
128
129
130
    String params = launchRequest.jobParameters;

    JobParameters jobParameters = jobParametersExtractor.fromString(params);

    try {
      JobExecution jobExecution = jobService.launch(jobName, jobParameters);
      model.addAttribute(new JobExecutionInfo(jobExecution, timeZone));
    }
    catch (NoSuchJobException e) {
      errors.reject("no.such.job", new Object[] { jobName }, "No such job: " + jobName);
    }
View Full Code Here
352
353
354
355
356
357
358
359
360
361
362
  }

  @Override
  public StepExecution getStepExecution(Long jobExecutionId, Long stepExecutionId)
      throws NoSuchJobExecutionException, NoSuchStepExecutionException {
    JobExecution jobExecution = getJobExecution(jobExecutionId);
    StepExecution stepExecution = stepExecutionDao.getStepExecution(jobExecution, stepExecutionId);
    if (stepExecution == null) {
      throw new NoSuchStepExecutionException("There is no StepExecution with jobExecutionId=" + jobExecutionId
          + " and id=" + stepExecutionId);
    }
View Full Code Here
485
486
487
488
489
490
491
492
493
494
495
496
497
498
499
500
501
502
   */
  @Scheduled(fixedDelay = 60000)
  public void removeInactiveExecutions() {

    for (Iterator<JobExecution> iterator = activeExecutions.iterator(); iterator.hasNext();) {
      JobExecution jobExecution = iterator.next();
      try {
        jobExecution = getJobExecution(jobExecution.getId());
      }
      catch (NoSuchJobExecutionException e) {
        logger.error("Unexpected exception loading JobExecution", e);
      }
      if (!jobExecution.isRunning()) {
        iterator.remove();
      }
    }

  }
View Full Code Here
45
46
47
48
49
50
51
52
53
54
55
56
  @Qualifier("jobs/executions.rss")
  private View view;

  @Test
  public void testLaunchedJobExecutions() throws Exception {
    JobExecution jobExecution = MetaDataInstanceFactory.createJobExecution();
    jobExecution.setEndTime(new Date());
    model.put("baseUrl", "http://localhost:8080/springsource");
    model.put("jobExecutions", Arrays.asList(new JobExecutionInfo(jobExecution, TimeZone.getTimeZone("GMT"))));
    model.put("currentTime", new Date());
    view.render(model, request, response);
    String content = response.getContentAsString();
View Full Code Here
60
61
62
63
64
65
66
67
68
69
70
71
72
    assertTrue(content.contains("id=12"));
  }

  @Test
  public void testUnfinishedJobExecutions() throws Exception {
    JobExecution jobExecution1 = MetaDataInstanceFactory.createJobExecution();
    JobExecution jobExecution2 = MetaDataInstanceFactory.createJobExecution(13L);
    jobExecution2.setEndTime(new Date());
    model.put("baseUrl", "http://localhost:8080/springsource");
    model.put("jobExecutions", Arrays.asList(new JobExecutionInfo(jobExecution1,
        TimeZone.getTimeZone("GMT")), new JobExecutionInfo(jobExecution2,
            TimeZone.getTimeZone("GMT"))));
    model.put("currentTime", new Date());
View Full Code Here
47
48
49
50
51
52
53
54
55
56
57
  @Qualifier("jobs/execution.json")
  private View view;

  @Test
  public void testLaunchViewWithJobExecutionInfo() throws Exception {
    JobExecution jobExecution = MetaDataInstanceFactory.createJobExecutionWithStepExecutions(123L, Arrays.asList(
        "foo", "bar"));
    model.put("jobExecutionInfo", new JobExecutionInfo(jobExecution, TimeZone.getDefault()));
    model.put("baseUrl", "http://localhost:8080/springsource");
    view.render(model, request, response);
    String content = response.getContentAsString();
View Full Code Here
64
65
66
67
68
69
70
71
72
73
74
75
76
77
        .get("jobExecution.stepExecutions.bar.resource"));
  }

  @Test
  public void testLaunchViewWithJobAndStepExecutionInfo() throws Exception {
    JobExecution jobExecution = MetaDataInstanceFactory.createJobExecutionWithStepExecutions(123L, Arrays.asList(
        "foo", "bar"));
    model.put("jobExecutionInfo", new JobExecutionInfo(jobExecution, TimeZone.getDefault()));
    model.put("stepExecutionInfos", Arrays.asList(new StepExecutionInfo(jobExecution.getStepExecutions().iterator()
        .next(), TimeZone.getTimeZone("GMT")), new StepExecutionInfo("job", 123L, "bar", TimeZone.getTimeZone("GMT"))));
    model.put("baseUrl", "http://localhost:8080/springsource");
    view.render(model, request, response);
    String content = response.getContentAsString();
    // System.err.println(content);
View Full Code Here
57
58
59
60
61
62
63
64
65
66
67
68
    exporter.getStepCount();
  }
 
  @Test
  public void testMBeanCreation() throws Exception {
    JobExecution jobExecution = jobRepository.createJobExecution("foo", new JobParameters());
    jobRepository.add(jobExecution.createStepExecution("step"));
    init();
    // System.err.println(server.queryNames(new ObjectName("*:type=JobExecution,name=foo,*"), null));
    assertEquals(2, server.queryNames(new ObjectName("*:type=JobExecution,name=foo,*"), null).size());
    assertEquals(1, server.queryNames(new ObjectName("*:type=JobExecution,name=foo,step=step,*"), null).size());
  }
View Full Code Here
TOP

Related Classes of org.springframework.batch.core.JobExecution

  • at.compax.bbsng.dataimport.app.service.ImportServiceImpl
  • com.iisigroup.cap.batch.handler.BatchHandler
  • com.springsource.insight.plugin.springbatch.SpringBatchOperationCollectionAspectTestSupport
  • com.vmware.bdd.manager.JobManager
  • org.apache.camel.component.spring.batch.SpringBatchProducer
  • org.springframework.batch.admin.integration.JobRestartRequestStringAdapterTests
  • org.springframework.batch.admin.jmx.BatchMBeanExporterIntegrationTests
  • org.springframework.batch.admin.jmx.SimpleJobExecutionMetrics
  • org.springframework.batch.admin.launch.JobLauncherSynchronizerIntegrationTests
  • org.springframework.batch.admin.sample.JobExecutionTests
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.