Skip to content

Commit 866062b

Browse files
committed
#62 added a missing test for the MisfireTestJob
1 parent 53a54dd commit 866062b

File tree

3 files changed

+27
-5
lines changed

3 files changed

+27
-5
lines changed

quartz-manager-parent/quartz-manager-web-showcase/src/main/java/it/fabioformosa/quartzmanager/jobs/tests/MisfireTestJob.java

+8-4
Original file line numberDiff line numberDiff line change
@@ -2,10 +2,9 @@
22

33
import it.fabioformosa.quartzmanager.api.jobs.AbstractQuartzManagerJob;
44
import it.fabioformosa.quartzmanager.api.jobs.entities.LogRecord;
5+
import lombok.NoArgsConstructor;
56
import lombok.extern.slf4j.Slf4j;
67
import org.quartz.JobExecutionContext;
7-
import org.slf4j.Logger;
8-
import org.slf4j.LoggerFactory;
98

109
/**
1110
* This job can be used to test the misfire policy. It pretends to be a long
@@ -15,16 +14,21 @@
1514
*
1615
*/
1716
@Slf4j
17+
@NoArgsConstructor
1818
public class MisfireTestJob extends AbstractQuartzManagerJob {
1919

20-
private Logger log = LoggerFactory.getLogger(MisfireTestJob.class);
20+
private long sleepPeriodInMs = 10 * 1000L;
21+
22+
public MisfireTestJob(long sleepPeriodInMs) {
23+
this.sleepPeriodInMs = sleepPeriodInMs;
24+
}
2125

2226
@Override
2327
public LogRecord doIt(JobExecutionContext jobExecutionContext) {
2428
try {
2529
log.info("{} is going to sleep...", Thread.currentThread().getName());
2630

27-
Thread.sleep(10 * 1000L);
31+
Thread.sleep(sleepPeriodInMs);
2832

2933
log.info("{} woke up!", Thread.currentThread().getName());
3034
} catch (InterruptedException e) {

quartz-manager-parent/quartz-manager-web-showcase/src/test/java/it/fabioformosa/QuartManagerApplicationTests.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66

77
@SpringBootTest(classes = QuartManagerDemoApplication.class)
88
@WebAppConfiguration
9-
class QuartManagerApplicationTests {
9+
public class QuartManagerApplicationTests {
1010

1111
@Test
1212
void contextLoads() {
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,18 @@
1+
package it.fabioformosa.quartzmanager.jobs.tests;
2+
3+
import it.fabioformosa.quartzmanager.api.jobs.entities.LogRecord;
4+
import org.assertj.core.api.Assertions;
5+
import org.junit.jupiter.api.Test;
6+
7+
class MisfireTestJobTest {
8+
9+
@Test
10+
void givenAMisfireTestJob_whenIsExecuted_shoulReturnALogRecord() {
11+
MisfireTestJob misfireTestJob = new MisfireTestJob(10L);
12+
LogRecord logRecord = misfireTestJob.doIt(null);
13+
Assertions.assertThat(logRecord.getMessage()).isEqualTo("Hello!");
14+
}
15+
16+
}
17+
18+

0 commit comments

Comments
 (0)