Creating multiple SpringBatch Job - Spring Batch Part2

By -
Let us consider, you own a corporate gift shop and its Christmas time!! You are accepting bulk orders and offer delivery. Lets see how to solve it using Spring Batch.


There are three steps involved in this process:
  1. Read an order 
  2. Package an order
  3. Ship the order for delivery

Let us create these three steps:
@Bean
public Step readOrderStep() {
   return this.stepBuilderFactory.get("readOrderStep").tasklet(new Tasklet() {
      @Override
      public RepeatStatus execute(StepContribution contribution, ChunkContext chunkContext) throws Exception {
         System.out.println("Order Received");
         return RepeatStatus.FINISHED;
      }
   }).build();
}

@Bean
public Step packageStep() {
   return this.stepBuilderFactory.get("packageStep").tasklet(new Tasklet() {
      @Override
      public RepeatStatus execute(StepContribution contribution, ChunkContext chunkContext) throws Exception {
         System.out.println("Packaging the gift");
         return RepeatStatus.FINISHED;
      }
   }).build();
}

@Bean
public Step deliveryStep() {
   return this.stepBuilderFactory.get("deliveryStep").tasklet(new Tasklet() {
      @Override
      public RepeatStatus execute(StepContribution contribution, ChunkContext chunkContext) throws Exception {
         System.out.println("Package out for delivery");
         return RepeatStatus.FINISHED;
      }
   }).build();
}
In order for our application to run these steps in an order, we use the next method on the JobBuilderFactory

@Bean
public Job packageJob(){
   return this.jobBuilderFactory.get("packageJob").start(readOrderStep())
         .next(packageStep())
         .next(deliveryStep()).build();
}
Lets run the application:


2020-07-16 23:23:28.681  INFO 23732 --- [           main] o.s.b.c.l.support.SimpleJobLauncher      : Job: [SimpleJob: [name=giftShopJob]] launched with the following parameters: [{}]
2020-07-16 23:23:28.742  INFO 23732 --- [           main] o.s.batch.core.job.SimpleStepHandler     : Executing step: [readOrderStep]
Order Received
2020-07-16 23:23:28.774  INFO 23732 --- [           main] o.s.batch.core.step.AbstractStep         : Step: [readOrderStep] executed in 32ms
2020-07-16 23:23:28.787  INFO 23732 --- [           main] o.s.batch.core.job.SimpleStepHandler     : Executing step: [packageStep]
Packaging the gift
2020-07-16 23:23:28.796  INFO 23732 --- [           main] o.s.batch.core.step.AbstractStep         : Step: [packageStep] executed in 9ms
2020-07-16 23:23:28.808  INFO 23732 --- [           main] o.s.batch.core.job.SimpleStepHandler     : Executing step: [deliveryStep]
Package out for delivery
2020-07-16 23:23:28.817  INFO 23732 --- [           main] o.s.batch.core.step.AbstractStep         : Step: [deliveryStep] executed in 9ms
2020-07-16 23:23:28.837  INFO 23732 --- [           main] o.s.b.c.l.support.SimpleJobLauncher      : Job: [SimpleJob: [name=giftShopJob]] completed with the following parameters: [{}] and the following status: [COMPLETED] in 106ms
2020-07-16 23:23:28.843  INFO 23732 --- [extShutdownHook] com.zaxxer.hikari.HikariDataSource       : HikariPool-1 - Shutdown initiated...
2020-07-16 23:23:28.861  INFO 23732 --- [extShutdownHook] com.zaxxer.hikari.HikariDataSource       : HikariPool-1 - Shutdown completed.

BUILD SUCCESSFUL in 4s
3 actionable tasks: 2 executed, 1 up-to-date
11:23:28 PM: Task execution finished 'SpringbootdemoApplication.main()'.



Comments

Post a Comment

Popular posts from this blog

Writing your own ejabberd Module

By -
Coming soon: What is ejabberd? What is erlang? Installation details. I will start with writing the ejabberd module first. Once you have done all the installations: sudo make sudo make install sudo ejabberdctl start sudo ejabberdctl stop You can check the status using: sudo ejabberdctl status You can locate logs at: (With default installation) /var/log/ejabberd All config related changes will be mainly done at: /etc/ejabberd/ejabberd.yml You will need a basic understanding of erlang. You can take a short crash course at: http://www.erlang.org/course/course.html This is a good reference. Go to your ejabberd-15.07/src directory. This is where you will write the hook for your ejabberd server. Create a file, say mod_changeBody.erl. Your module name and file name should be same. Add the following basic contents into your erl file: -module(mod_changeBody). -behavior(gen_mod). -include("ejabberd.hrl"). -include("logger.hrl"). -expo
Read more

npm ECONNREFUSED error

By -
If you face error which says ECONNREFUSED while doing npm install <<package name>>, you are probably behind a proxy which is not allowing you to connect to the server and download the packages required. Just follow the below steps: npm config set proxy  http://your_proxy_name:port npm config set https-proxy https://your_proxy_name:port And then try npm install How to get npm config? npm get proxy will do the work :)
Read more

Conditional Flow - Spring Batch Part 6

By -
Jump to Conditional Flow using Custom Status There can be muliple scenario where you want your jobs to proceed depending on the outcome of your steps. For example, in case of our Corporate gifts shop, in case the automatic packaging of the gifts fails, we want some manual intervention to be done i.e. somebody should manually package the item.  IF-ELSE IF loop for packaging:     if packageStep fails                              then manualPackageStep                         else if packageStep executes successfully                              then sendOutForDelivery Entire code available at git repo:   https://github.com/ricsr/spring-batch-demo/tree/exercise_06 Using SpringBatch you can achieve it as follows: Create you manualPackageStep, which is very similar to your packageStep, except that it does the packaging manually. @Bean public Step manualPackageStep () { return this . stepBuilderFactory .get( "manualPackageStep" ).tasklet( new Tasklet() { @Override pu
Read more