diff --git a/quartz-manager-parent/quartz-manager-web-showcase/src/main/java/it/fabioformosa/quartzmanager/jobs/tests/MisfireTestJob.java b/quartz-manager-parent/quartz-manager-web-showcase/src/main/java/it/fabioformosa/quartzmanager/jobs/tests/MisfireTestJob.java index dc21ef3..169b381 100644 --- a/quartz-manager-parent/quartz-manager-web-showcase/src/main/java/it/fabioformosa/quartzmanager/jobs/tests/MisfireTestJob.java +++ b/quartz-manager-parent/quartz-manager-web-showcase/src/main/java/it/fabioformosa/quartzmanager/jobs/tests/MisfireTestJob.java @@ -2,10 +2,9 @@ package it.fabioformosa.quartzmanager.jobs.tests; import it.fabioformosa.quartzmanager.api.jobs.AbstractQuartzManagerJob; import it.fabioformosa.quartzmanager.api.jobs.entities.LogRecord; +import lombok.NoArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.quartz.JobExecutionContext; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; /** * This job can be used to test the misfire policy. It pretends to be a long @@ -15,16 +14,21 @@ import org.slf4j.LoggerFactory; * */ @Slf4j +@NoArgsConstructor public class MisfireTestJob extends AbstractQuartzManagerJob { - private Logger log = LoggerFactory.getLogger(MisfireTestJob.class); + private long sleepPeriodInMs = 10 * 1000L; + + public MisfireTestJob(long sleepPeriodInMs) { + this.sleepPeriodInMs = sleepPeriodInMs; + } @Override public LogRecord doIt(JobExecutionContext jobExecutionContext) { try { log.info("{} is going to sleep...", Thread.currentThread().getName()); - Thread.sleep(10 * 1000L); + Thread.sleep(sleepPeriodInMs); log.info("{} woke up!", Thread.currentThread().getName()); } catch (InterruptedException e) { diff --git a/quartz-manager-parent/quartz-manager-web-showcase/src/test/java/it/fabioformosa/QuartManagerApplicationTests.java b/quartz-manager-parent/quartz-manager-web-showcase/src/test/java/it/fabioformosa/QuartManagerApplicationTests.java index 02a6f98..d1b7d9a 100644 --- a/quartz-manager-parent/quartz-manager-web-showcase/src/test/java/it/fabioformosa/QuartManagerApplicationTests.java +++ b/quartz-manager-parent/quartz-manager-web-showcase/src/test/java/it/fabioformosa/QuartManagerApplicationTests.java @@ -6,7 +6,7 @@ import org.springframework.test.context.web.WebAppConfiguration; @SpringBootTest(classes = QuartManagerDemoApplication.class) @WebAppConfiguration -class QuartManagerApplicationTests { +public class QuartManagerApplicationTests { @Test void contextLoads() { diff --git a/quartz-manager-parent/quartz-manager-web-showcase/src/test/java/it/fabioformosa/quartzmanager/jobs/tests/MisfireTestJobTest.java b/quartz-manager-parent/quartz-manager-web-showcase/src/test/java/it/fabioformosa/quartzmanager/jobs/tests/MisfireTestJobTest.java new file mode 100644 index 0000000..db60521 --- /dev/null +++ b/quartz-manager-parent/quartz-manager-web-showcase/src/test/java/it/fabioformosa/quartzmanager/jobs/tests/MisfireTestJobTest.java @@ -0,0 +1,18 @@ +package it.fabioformosa.quartzmanager.jobs.tests; + +import it.fabioformosa.quartzmanager.api.jobs.entities.LogRecord; +import org.assertj.core.api.Assertions; +import org.junit.jupiter.api.Test; + +class MisfireTestJobTest { + + @Test + void givenAMisfireTestJob_whenIsExecuted_shoulReturnALogRecord() { + MisfireTestJob misfireTestJob = new MisfireTestJob(10L); + LogRecord logRecord = misfireTestJob.doIt(null); + Assertions.assertThat(logRecord.getMessage()).isEqualTo("Hello!"); + } + +} + +