Xtykutl

I have a writer from which I have a dynamic value that needs to be passed to JobExecutionListener's afterJob(JobExecution jobExecution). Would appreciate some advice. Thank you.

<beans:bean>

    <job id="GoodJob">

        <step id="XXX"

              allow-start-if-complete="true"

              parent="XXX">

            <tasklet transaction-manager="XXX">

                <chunk reader="READER"

                       writer="WRITER"

                       commit-interval="100"/>

            </tasklet>

        </step>



        <listener>

            <beans:bean class="class that implements JobExecutionListener">

                <beans:constructor-arg name="value"

                                       value="DEFAULT IS FALSE DURING INITIALIZATION/MIGHT GET CHANGED IN WRITER, GET THIS VALUE FROM WRITER"/>

            </beans:bean>

        </listener>

    </job>

</beans:beans>

You can pass data between these two components through the job execution context. This is detailed in the Passing Data to Future Steps section. Here is a quick example:

import java.util.Arrays;

import java.util.List;



import org.springframework.batch.core.Job;

import org.springframework.batch.core.JobExecution;

import org.springframework.batch.core.JobExecutionListener;

import org.springframework.batch.core.JobParameters;

import org.springframework.batch.core.Step;

import org.springframework.batch.core.StepExecution;

import org.springframework.batch.core.annotation.BeforeStep;

import org.springframework.batch.core.configuration.annotation.EnableBatchProcessing;

import org.springframework.batch.core.configuration.annotation.JobBuilderFactory;

import org.springframework.batch.core.configuration.annotation.StepBuilderFactory;

import org.springframework.batch.core.launch.JobLauncher;

import org.springframework.batch.item.ExecutionContext;

import org.springframework.batch.item.ItemReader;

import org.springframework.batch.item.ItemWriter;

import org.springframework.batch.item.support.ListItemReader;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.context.ApplicationContext;

import org.springframework.context.annotation.AnnotationConfigApplicationContext;

import org.springframework.context.annotation.Bean;

import org.springframework.context.annotation.Configuration;



@Configuration

@EnableBatchProcessing

public class MyJob {



    @Autowired

    private JobBuilderFactory jobs;



    @Autowired

    private StepBuilderFactory steps;



    @Bean

    public ItemReader<Integer> itemReader() {

        return new ListItemReader<>(Arrays.asList(1, 2, 3, 4));

    }



    @Bean

    public ItemWriter<Integer> itemWriter() {

        return new ItemWriter<Integer>() {



            private StepExecution stepExecution;



            @Override

            public void write(List<? extends Integer> items) throws Exception {

                for (Integer item : items) {

                    System.out.println("item = " + item);

                }

                stepExecution.getJobExecution().getExecutionContext().put("data", "foo");

            }



            @BeforeStep

            public void saveStepExecution(StepExecution stepExecution) {

                this.stepExecution = stepExecution;

            }



        };

    }



    @Bean

    public Step step() {

        return steps.get("step")

                .<Integer, Integer>chunk(2)

                .reader(itemReader())

                .writer(itemWriter())

                .build();

    }



    @Bean

    public Job job() {

        return jobs.get("job")

                .start(step())

                .listener(new JobExecutionListener() {

                    @Override

                    public void beforeJob(JobExecution jobExecution) {



                    }



                    @Override

                    public void afterJob(JobExecution jobExecution) {

                        ExecutionContext executionContext = jobExecution.getExecutionContext();

                        String data = executionContext.getString("data");

                        System.out.println("data from writer = " + data);

                    }

                })

                .build();

    }



    public static void main(String args) throws Exception {

        ApplicationContext context = new AnnotationConfigApplicationContext(MyJob.class);

        JobLauncher jobLauncher = context.getBean(JobLauncher.class);

        Job job = context.getBean(Job.class);

        jobLauncher.run(job, new JobParameters());

    }



}

In this example, the writer writes the key data with value foo in the job execution context. Then, this key is retrieved from the execution context in the job listener.

Hope this helps.