Spring Batch: One reader, multiple processors and writers

by

This solution is valid if your item should be processed by processor #1 and processor #2

You have to create a processor #0 with this signature:

class Processor0<Item, CompositeResultBean>

where CompositeResultBean is a bean defined as

class CompositeResultBean {
  Processor1ResultBean result1;
  Processor2ResultBean result2;
}

In your Processor #0 just delegate work to processors #1 and #2 and put result in CompositeResultBean

CompositeResultBean Processor0.process(Item item) {
  final CompositeResultBean r = new CompositeResultBean();
  r.setResult1(processor1.process(item));
  r.setResult2(processor2.process(item));
  return r;
}

Your own writer is a CompositeItemWriter that delegate to writer CompositeResultBean.result1 or CompositeResultBean.result2 (look at PropertyExtractingDelegatingItemWriter, maybe can help)

More Related Contents:

  1. How to java-configure separate datasources for spring batch data and business data? Should I even do it?
  2. Spring Batch With Annotation and Caching
  3. Unable to locate Spring NamespaceHandler for XML schema namespace [http://www.springframework.org/schema/batch]
  4. How does Spring Batch CompositeItemWriter manage transaction for delegate writers?
  5. Failed to configure a DataSource: ‘url’ attribute is not specified and no embedded datasource could be configured
  6. Spring batch scope issue while using spring boot
  7. Storing in JobExecutionContext from tasklet and accessing in another tasklet
  8. Spring Batch: Reading fixed-width file without line breaks
  9. Spring Batch skip exception for ItemWriter
  10. SPRING MVC getting 404 error in when you hits the submit button
  11. What is the difference between ApplicationContext and WebApplicationContext in Spring MVC?
  12. How does spring.jpa.hibernate.ddl-auto property exactly work in Spring?
  13. Spring @Autowire on Properties vs Constructor
  14. Use of multiple DataSources in Spring Batch
  15. Spring Boot – How to get the running port
  16. create two method for same url pattern with different arguments
  17. Fire and forget with reactor
  18. Where should “@Transactional” be placed Service Layer or DAO
  19. Spring Data – ignore parameter if it has a null value
  20. spring autowiring with unique beans: Spring expected single matching bean but found 2
  21. User Defined Type with spring-data-cassandra
  22. What is Dependency Injection and Inversion of Control in Spring Framework?
  23. What is the difference between @Configuration and @Component in Spring?
  24. Changing default welcome-page for spring-boot application deployed as a war
  25. What is the order of precedence when there are multiple Spring’s environment profiles as set by spring.profiles.active
  26. Performance impact of using aop
  27. How to allow a User only access their own data in Spring Boot / Spring Security?
  28. Spring – How to stream large multipart file uploads to database without storing on local file system [duplicate]
  29. How does backpressure work in Project Reactor?
  30. spring property substitution for test and production

Leave a Comment