add sample test for Quartz integration

yavuztas · yavuztas · commit 29f039ff9714 · 2020-08-09T15:57:28.000+02:00
diff --git a/spring-boot/bean-lifecycle/src/main/java/io/reflectoring/beanlifecycle/quartz/QuartzConfig.java b/spring-boot/bean-lifecycle/src/main/java/io/reflectoring/beanlifecycle/quartz/QuartzConfig.java
@@ -5,24 +5,28 @@
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 import org.springframework.scheduling.quartz.SchedulerFactoryBean;
+import org.springframework.scheduling.quartz.SpringBeanJobFactory;
 
 @Configuration
 public class QuartzConfig {
 
     @Autowired
     ApplicationContext applicationContext;
 
+    @Bean
+    public SpringBeanJobFactory springBeanJobFactory() {
+        AutowireCapableJobFactory jobFactory = new AutowireCapableJobFactory();
+        jobFactory.setApplicationContext(applicationContext);
+        return jobFactory;
+    }
+
     /**
      * Create custom {@link SchedulerFactoryBean} for Quartz
      */
     @Bean
     public SchedulerFactoryBean schedulerFactoryBean(){
-        AutowireCapableJobFactory jobFactory = new AutowireCapableJobFactory();
-        jobFactory.setApplicationContext(applicationContext);
-
         SchedulerFactoryBean factoryBean = new SchedulerFactoryBean();
-        factoryBean.setJobFactory(jobFactory);
-
+        factoryBean.setJobFactory(springBeanJobFactory());
         return factoryBean;
     }
 
diff --git a/spring-boot/bean-lifecycle/src/main/java/io/reflectoring/beanlifecycle/quartz/SampleJob.java b/spring-boot/bean-lifecycle/src/main/java/io/reflectoring/beanlifecycle/quartz/SampleJob.java
@@ -0,0 +1,16 @@
+package io.reflectoring.beanlifecycle.quartz;
+
+import org.quartz.Job;
+import org.quartz.JobExecutionContext;
+import org.springframework.beans.factory.annotation.Autowired;
+
+public class SampleJob implements Job {
+
+    @Autowired
+    private SampleServiceBean service;
+
+    @Override
+    public void execute(JobExecutionContext jobExecutionContext) {
+        service.hello();
+    }
+}
diff --git a/spring-boot/bean-lifecycle/src/main/java/io/reflectoring/beanlifecycle/quartz/SampleServiceBean.java b/spring-boot/bean-lifecycle/src/main/java/io/reflectoring/beanlifecycle/quartz/SampleServiceBean.java
@@ -0,0 +1,16 @@
+package io.reflectoring.beanlifecycle.quartz;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.stereotype.Service;
+
+@Service
+public class SampleServiceBean {
+
+    Logger logger = LoggerFactory.getLogger(SampleServiceBean.class);
+
+    public void hello() {
+        logger.info("hello from Quartz Job!");
+    }
+
+}
diff --git a/spring-boot/bean-lifecycle/src/test/java/io/reflectoring/beanlifecycle/quartz/SpringQuartzTests.java b/spring-boot/bean-lifecycle/src/test/java/io/reflectoring/beanlifecycle/quartz/SpringQuartzTests.java
@@ -0,0 +1,27 @@
+package io.reflectoring.beanlifecycle.quartz;
+
+import org.junit.jupiter.api.Test;
+import org.quartz.*;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+
+@SpringBootTest
+public class SpringQuartzTests {
+
+    @Autowired
+    Scheduler quartzScheduler;
+
+    @Test
+    public void testQuartzJobHasCapabaleOfAutowireSpringBeans() throws SchedulerException, InterruptedException {
+
+        JobDetail jobDetail = JobBuilder.newJob(SampleJob.class).build();
+        Trigger trigger = TriggerBuilder.newTrigger()
+                .withSchedule(SimpleScheduleBuilder.repeatSecondlyForever())
+                .startNow().build();
+        quartzScheduler.scheduleJob(jobDetail, trigger);
+
+        Thread.sleep(5000);
+
+    }
+
+}
