Package org.springframework.batch.core.step.tasklet

Examples of org.springframework.batch.core.step.tasklet.Tasklet

371
372
373
374
375
376
377
378
379
380
381
  }

  @Test
  public void testRepositoryErrorOnUpdateStepExecutionInTransaction() throws Exception {

    taskletStep.setTasklet(new Tasklet() {

      @Override
      public RepeatStatus execute(StepContribution contribution, ChunkContext attributes) throws Exception {
        return RepeatStatus.FINISHED;
      }
View Full Code Here
392
393
394
395
396
397
398
399
400
401
402
  }

  @Test
  public void testRepositoryErrorOnUpdateStepExecutionInTransactionRollbackFailed() throws Exception {

    taskletStep.setTasklet(new Tasklet() {

      @Override
      public RepeatStatus execute(StepContribution contribution, ChunkContext attributes) throws Exception {
        return RepeatStatus.FINISHED;
      }
View Full Code Here
415
416
417
418
419
420
421
422
423
424
425
  }

  @Test
  public void testRepositoryErrorOnFailure() throws Exception {

    taskletStep.setTasklet(new Tasklet() {

      @Override
      public RepeatStatus execute(StepContribution contribution, ChunkContext attributes) throws Exception {
        throw new RuntimeException("Tasklet exception");
      }
View Full Code Here
53
54
55
56
57
58
59
60
61
62
63
    jobLauncher.setTaskExecutor(new SimpleAsyncTaskExecutor());
    jobLauncher.afterPropertiesSet();

    SimpleJob job = new SimpleJob("job");
    TaskletStep step = new TaskletStep("step");
    step.setTasklet(new Tasklet() {
      @Override
      public RepeatStatus execute(StepContribution contribution, ChunkContext chunkContext) throws Exception {
        while (block) {
          Thread.sleep(100L);
        }
View Full Code Here
128
129
130
131
132
133
134
135
136
137
138
      return steps.get("step2").tasklet(tasklet()).build();
    }

    @Bean
    protected Tasklet tasklet() {
      return new Tasklet() {
        @Override
        public RepeatStatus execute(StepContribution contribution, ChunkContext context) throws Exception {
          if (fail) {
            throw new RuntimeException("Planned!");
          }
View Full Code Here
407
408
409
410
411
412
413
414
415
416
417
          if (stepExecution.getStatus().isRunning()) {
            try {
              //have the step execution that's running -> need to 'stop' it
              Step step = ((StepLocator)job).getStep(stepExecution.getStepName());
              if (step instanceof TaskletStep) {
                Tasklet tasklet = ((TaskletStep)step).getTasklet();
                if (tasklet instanceof StoppableTasklet) {
                  StepSynchronizationManager.register(stepExecution);
                  ((StoppableTasklet)tasklet).stop();
                  StepSynchronizationManager.release();
                }
View Full Code Here
723
724
725
726
727
728
729
730
731
732
733
          if (stepExecution.getStatus().isRunning()) {
            try {
              //have the step execution that's running -> need to 'stop' it
              Step step = ((StepLocator)job).getStep(stepExecution.getStepName());
              if (step instanceof TaskletStep) {
                Tasklet tasklet = ((TaskletStep)step).getTasklet();
                if (tasklet instanceof StoppableTasklet) {
                  StepSynchronizationManager.register(stepExecution);
                  ((StoppableTasklet)tasklet).stop();
                  StepSynchronizationManager.release();
                }
View Full Code Here
62
63
64
65
66
67
68
69
70
71
72
    @Autowired
    public StepBuilderFactory stepBuilderFactory;

    @Bean
    public Step step() {
      return stepBuilderFactory.get("step1").tasklet(new Tasklet() {
        @Override
        public RepeatStatus execute(StepContribution contribution, ChunkContext chunkContext) throws Exception {
          return null;
        }
      }).build();
View Full Code Here
40
41
42
43
44
45
46
47
48
49
50
  @Autowired
  private StepBuilderFactory steps;

  @Bean
  protected Tasklet tasklet() {
    return new Tasklet() {
      @Override
      public RepeatStatus execute(StepContribution contribution,
          ChunkContext context) {
        return RepeatStatus.FINISHED;
      }
View Full Code Here
76
77
78
79
80
81
82
83
84
85
86
    this.jobLauncher = this.context.getBean(JobLauncher.class);
    this.jobs = new JobBuilderFactory(jobRepository);
    PlatformTransactionManager transactionManager = this.context
        .getBean(PlatformTransactionManager.class);
    this.steps = new StepBuilderFactory(jobRepository, transactionManager);
    this.step = this.steps.get("step").tasklet(new Tasklet() {
      @Override
      public RepeatStatus execute(StepContribution contribution,
          ChunkContext chunkContext) throws Exception {
        return null;
      }
View Full Code Here
TOP

Related Classes of org.springframework.batch.core.step.tasklet.Tasklet

  • com.springsource.insight.plugin.springbatch.TaskletCollectionAspectTest
  • org.springframework.batch.core.configuration.annotation.JobBuilderConfigurationTests$BeansConfigurer
  • org.springframework.batch.core.configuration.annotation.JobBuilderConfigurationTests$TestConfiguration
  • org.springframework.batch.core.configuration.annotation.JobLoaderConfigurationTests$TestConfiguration
  • org.springframework.batch.core.configuration.annotation.JobLoaderConfigurationTests$VanillaConfiguration
  • org.springframework.batch.core.configuration.annotation.MapJobRepositoryConfigurationTests$MapRepositoryBatchConfiguration
  • org.springframework.batch.core.explore.support.MapJobExplorerIntegrationTests
  • org.springframework.batch.core.jsr.launch.JsrJobOperator
  • org.springframework.batch.core.launch.support.SimpleJobOperator
  • org.springframework.batch.core.step.builder.StepBuilderTests
    • 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.