Choose Bean from Multiple Implementation in Spring Boot

Author: nilandev

quartz-scheduler/src/main/java/com/stacktips/app/config/QuartzConfig.java

@@ -5,6 +5,10 @@
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 
+import java.time.LocalDateTime;
+import java.time.ZoneId;
+import java.util.Date;
+
 @Configuration
 public class QuartzConfig {
 
@@ -27,23 +31,23 @@ public Trigger csvImportJobTrigger(JobDetail csvImportJob) {
     }
 
 
-    /*
-    // Commented out in favour of Cron based trigger
 
-    @Bean
-    public Trigger csvImportJobTrigger(JobDetail csvImportJob) {
-        Date afterFiveSeconds = Date.from(LocalDateTime.now().plusSeconds(5)
-                .atZone(ZoneId.systemDefault()).toInstant());
+    // Commented out in favour of Cron based trigger
 
-        return TriggerBuilder.newTrigger()
-                .forJob(csvImportJob)
-                .startAt(afterFiveSeconds)
-                .withIdentity("simpleTrigger")
-                .withSchedule(SimpleScheduleBuilder.simpleSchedule()
-                        .withIntervalInSeconds(60)
-                        .repeatForever())
-                .build();
-    }*/
+//    @Bean
+//    public Trigger csvImportJobTrigger(JobDetail csvImportJob) {
+//        Date afterFiveSeconds = Date.from(LocalDateTime.now().plusSeconds(5)
+//                .atZone(ZoneId.systemDefault()).toInstant());
+//
+//        return TriggerBuilder.newTrigger()
+//                .forJob(csvImportJob)
+//                .startAt(afterFiveSeconds)
+//                .withIdentity("simpleTrigger")
+//                .withSchedule(SimpleScheduleBuilder.simpleSchedule()
+//                        .withIntervalInSeconds(60)
+//                        .repeatForever())
+//                .build();
+//    }
 
 
 }

quartz-scheduler/src/main/java/com/stacktips/app/model/Book.java

@@ -11,4 +11,4 @@ public record Book(
         String languageCode,
         Double averageRating,
         String imageUrl) {
-}
+}

quartz-scheduler/src/main/java/com/stacktips/app/service/QuartzJobService.java

@@ -2,6 +2,7 @@
 
 import com.stacktips.app.tasks.CsvImportInterruptableJob;
 import org.quartz.*;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
 @Service

quartz-scheduler/src/main/java/com/stacktips/app/tasks/CsvImportJob.java

@@ -24,7 +24,7 @@ public CsvImportJob(ImportService importService) {
     public void execute(JobExecutionContext context) throws JobExecutionException {
         try {
             JobDataMap dataMap = context.getJobDetail().getJobDataMap();
-            String param = dataMap.getString("param");
+            String param = dataMap.getString("arg1");
 
             log.info("CsvImportJob started with param: {}", param);
             importService.readBooks();

run-on-startup/gradle/wrapper/gradle-wrapper.jar

@@ -0,0 +1,7 @@
+distributionBase=GRADLE_USER_HOME
+distributionPath=wrapper/dists
+distributionUrl=https\://services.gradle.org/distributions/gradle-8.2-bin.zip
+networkTimeout=10000
+validateDistributionUrl=true
+zipStoreBase=GRADLE_USER_HOME
+zipStorePath=wrapper/dists

run-on-startup/gradle/wrapper/gradle-wrapper.properties

@@ -3,6 +3,7 @@
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.scheduling.annotation.EnableScheduling;
 
 import javax.annotation.PostConstruct;
 

run-on-startup/gradlew

@@ -0,0 +1,20 @@
+package com.stacktips;
+
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.scheduling.annotation.EnableScheduling;
+import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
+
+@Configuration
+@EnableScheduling
+public class SchedulerConfig {
+
+
+    @Bean
+    public ThreadPoolTaskScheduler threadPoolTaskScheduler() {
+        ThreadPoolTaskScheduler threadPoolTaskScheduler = new ThreadPoolTaskScheduler();
+        threadPoolTaskScheduler.setPoolSize(5);
+        return threadPoolTaskScheduler;
+    }
+
+}