Java 类org.springframework.batch.core.JobExecution 实例源码

项目：composed-task-runner 文件：ComposedTaskRunnerConfigurationWithPropertiesTests.java

@Test
@DirtiesContext
public void testComposedConfiguration() throws Exception {
    JobExecution jobExecution = this.jobRepository.createJobExecution(
            "ComposedTest", new JobParameters());
    job.execute(jobExecution);

    Map<String, String> props = new HashMap<>(1);
    props.put("format", "yyyy");
    assertEquals(1010, composedTaskProperties.getMaxWaitTime());
    assertEquals(1100, composedTaskProperties.getIntervalTimeBetweenChecks());
    assertEquals("http://bar", composedTaskProperties.getDataflowServerUri().toASCIIString());

    List<String> args = new ArrayList<>(1);
    args.add("--baz=boo");
    Assert.isNull(job.getJobParametersIncrementer(), "JobParametersIncrementer must be null.");
    verify(this.taskOperations).launch("AAA", props, args);
}

项目：composed-task-runner 文件：ComposedTaskRunnerConfigurationNoPropertiesTests.java

@Test
@DirtiesContext
public void testComposedConfiguration() throws Exception {
    JobExecution jobExecution = this.jobRepository.createJobExecution(
            "ComposedTest", new JobParameters());
    job.execute(jobExecution);

    Assert.isNull(job.getJobParametersIncrementer(), "JobParametersIncrementer must be null.");
    verify(this.taskOperations).launch("AAA", new HashMap<String, String>(0), new ArrayList<String>(0));
}

项目：nixmash-blog 文件：DemoJobRunner.java

@Scheduled(fixedDelayString = "${demo.job.fixed.delay.seconds:60}000")
public void runDemoJob() {

    SimpleDateFormat format = new SimpleDateFormat("M-dd-yy hh:mm:ss");
    String startDateTime = format.format(new Date());

    JobParameters jobParameters =
            new JobParametersBuilder()
                    .addLong("iterations", iterations)
                    .addString("username", username)
                    .addLong("time", System.currentTimeMillis()).toJobParameters();

    try {
        logger.info("");
        logger.info("STARTING BATCH JOB AT " + startDateTime);
        JobExecution execution = jobLauncher.run(demoJob, jobParameters);
        logger.info("JOB STATUS : " + execution.getStatus());
    } catch (Exception e) {
        e.printStackTrace();
        logger.info("JOB FAILED!!!");
    }

}

项目：kowalski 文件：Application.java

public void start() throws IOException, InterruptedException {
    List<JobExecution> jobExecutions = new ArrayList<>();
    // launch jobs
    jobExecutions.addAll(IntStream.range(0, this.cardinality).mapToObj(i -> {
        Job analysisJob = this.jobFactory.get();
        JobParametersBuilder jobParametersBuilder = new JobParametersBuilder();
        jobParametersBuilder.addString("id", analysisJob.getName() + "-" + i, true);
        try {
            return this.jobLauncher.run(analysisJob, jobParametersBuilder.toJobParameters());
        } catch (JobExecutionAlreadyRunningException | JobRestartException | JobInstanceAlreadyCompleteException
                | JobParametersInvalidException exception) {
            throw new RuntimeException(exception);
        }
    }).collect(Collectors.toList()));
    // wait for termination
    while (jobExecutions.stream().anyMatch(jobExecution -> jobExecution.getStatus().isRunning())) {
        Thread.sleep(1000);
    }
}

项目：oma-riista-web 文件：LHHuntingClubCSVCleaner.java

@Override
public void afterJob(final JobExecution jobExecution) {
    if (ExitStatus.COMPLETED.equals(jobExecution.getExitStatus())) {
        final ExecutionContext executionContext = jobExecution.getExecutionContext();
        final String inputFile = executionContext.getString(LHHuntingClubBatchConfig.KEY_INPUT_FILE, null);

        if (inputFile != null) {
            final Path path = Paths.get(inputFile);

            try {
                LOG.info("Deleting temporary file: {}", inputFile);
                Files.deleteIfExists(path);

            } catch (IOException e) {
                e.printStackTrace();
            }
        } else {
            LOG.warn("Input file not found in context");
        }
    }
}

项目：https-github.com-g0t4-jenkins2-course-spring-boot 文件：BatchAutoConfigurationTests.java

@Bean
public Job discreteJob() {
    AbstractJob job = new AbstractJob("discreteRegisteredJob") {

        @Override
        public Collection<String> getStepNames() {
            return Collections.emptySet();
        }

        @Override
        public Step getStep(String stepName) {
            return null;
        }

        @Override
        protected void doExecute(JobExecution execution)
                throws JobExecutionException {
            execution.setStatus(BatchStatus.COMPLETED);
        }
    };
    job.setJobRepository(this.jobRepository);
    return job;
}

项目：https-github.com-g0t4-jenkins2-course-spring-boot 文件：BatchAutoConfigurationTests.java

@Bean
public Job discreteJob() {
    AbstractJob job = new AbstractJob("discreteLocalJob") {

        @Override
        public Collection<String> getStepNames() {
            return Collections.emptySet();
        }

        @Override
        public Step getStep(String stepName) {
            return null;
        }

        @Override
        protected void doExecute(JobExecution execution)
                throws JobExecutionException {
            execution.setStatus(BatchStatus.COMPLETED);
        }
    };
    job.setJobRepository(this.jobRepository);
    return job;
}

项目：SpringRestBatch 文件：JobCompletionNotificationListener.java

@Override
    public void afterJob(JobExecution jobExecution) {

        LOGGER.info("RUNNING JobCompletion Check.");

        long cnt = movieRepository.count();

        LOGGER.info("Total Movies Saved: {}", cnt);

//        Shutdown when Job is Finished (for Windows PC)
//        Runtime runtime = Runtime.getRuntime();
//        String command = "shutdown /s";
//        try {
//            Process proc = runtime.exec(command);
//        } catch (IOException e) {
//            System.out.println(e.getMessage());
//            e.printStackTrace();
//        }

     }

项目：spring-boot-concourse 文件：BatchAutoConfigurationTests.java

@Bean
public Job discreteJob() {
    AbstractJob job = new AbstractJob("discreteRegisteredJob") {

        @Override
        public Collection<String> getStepNames() {
            return Collections.emptySet();
        }

        @Override
        public Step getStep(String stepName) {
            return null;
        }

        @Override
        protected void doExecute(JobExecution execution)
                throws JobExecutionException {
            execution.setStatus(BatchStatus.COMPLETED);
        }
    };
    job.setJobRepository(this.jobRepository);
    return job;
}

项目：spring-boot-concourse 文件：BatchAutoConfigurationTests.java

@Bean
public Job discreteJob() {
    AbstractJob job = new AbstractJob("discreteLocalJob") {

        @Override
        public Collection<String> getStepNames() {
            return Collections.emptySet();
        }

        @Override
        public Step getStep(String stepName) {
            return null;
        }

        @Override
        protected void doExecute(JobExecution execution)
                throws JobExecutionException {
            execution.setStatus(BatchStatus.COMPLETED);
        }
    };
    job.setJobRepository(this.jobRepository);
    return job;
}