Search code examples
javaspringspring-mvcspring-batchspring-batch-admin

How to get Job parameteres in to item processor using spring Batch annotation


I am using spring MVC. From my controller, I am calling jobLauncher and in jobLauncher I am passing job parameters like below and I'm using annotations to enable configuration as below:

@Configuration
@EnableBatchProcessing
public class BatchConfiguration {
        // read, write ,process and invoke job
} 

JobParameters jobParameters = new JobParametersBuilder().addString("fileName", "xxxx.txt").toJobParameters();
stasrtjob = jobLauncher.run(job, jobParameters);                              

and here is my itemprocessor                                                         
public class DataItemProcessor implements ItemProcessor<InputData, OutPutData> {

  public OutPutData process(final InputData inputData) throws Exception {

        // i want to get job Parameters here ????

  }

}

Solution

  • 1) Put a scope annotation on your data processor i.e.

    @Scope(value = "step") 
    

    2) Make a class instance in your data processor and inject the job parameter value by using value annotation :

    @Value("#{jobParameters['fileName']}")
    private String fileName;
    

    Your final Data processor class will look like:

    @Scope(value = "step")
    public class DataItemProcessor implements ItemProcessor<InputData, OutPutData> {
    
    @Value("#{jobParameters['fileName']}")
    private String fileName;
    
      public OutPutData process(final InputData inputData) throws Exception {
    
            // i want to get job Parameters here ????
          System.out.println("Job parameter:"+fileName);
    
      }
    
      public void setFileName(String fileName) {
            this.fileName = fileName;
        }
    
    
    }
    

    In case your data processor is not initialized as a bean, put a @Component annotation on it:

    @Component("dataItemProcessor")
    @Scope(value = "step")
    public class DataItemProcessor implements ItemProcessor<InputData, OutPutData> {