diff --git a/quartz-manager-parent/quartz-manager-starter-api/src/main/java/it/fabioformosa/quartzmanager/api/exceptions/TriggerNotFoundException.java b/quartz-manager-parent/quartz-manager-starter-api/src/main/java/it/fabioformosa/quartzmanager/api/exceptions/TriggerNotFoundException.java index b58cb89..d3e0113 100644 --- a/quartz-manager-parent/quartz-manager-starter-api/src/main/java/it/fabioformosa/quartzmanager/api/exceptions/TriggerNotFoundException.java +++ b/quartz-manager-parent/quartz-manager-starter-api/src/main/java/it/fabioformosa/quartzmanager/api/exceptions/TriggerNotFoundException.java @@ -1,8 +1,5 @@ package it.fabioformosa.quartzmanager.api.exceptions; -import lombok.ToString; - -@ToString public class TriggerNotFoundException extends Exception { public TriggerNotFoundException(String name) { super("Trigger with name " + name + " not found!"); diff --git a/quartz-manager-parent/quartz-manager-starter-api/src/main/java/it/fabioformosa/quartzmanager/api/websockets/WebSocketProgressNotifier.java b/quartz-manager-parent/quartz-manager-starter-api/src/main/java/it/fabioformosa/quartzmanager/api/websockets/WebSocketProgressNotifier.java index 464a12d..7eeba6d 100644 --- a/quartz-manager-parent/quartz-manager-starter-api/src/main/java/it/fabioformosa/quartzmanager/api/websockets/WebSocketProgressNotifier.java +++ b/quartz-manager-parent/quartz-manager-starter-api/src/main/java/it/fabioformosa/quartzmanager/api/websockets/WebSocketProgressNotifier.java @@ -43,7 +43,7 @@ public class WebSocketProgressNotifier implements WebhookSender { + Assertions.assertThat(actualLogRecord.getMessage()).isEqualTo("Hello!"); + Assertions.assertThat(actualLogRecord.getType()).isEqualTo(LogRecord.LogType.INFO); + Assertions.assertThat(actualLogRecord.getDate()).isNotNull(); + Assertions.assertThat(actualLogRecord.getThreadName()).isNotNull(); + return true; + })); + Mockito.verify(webSocketProgressNotifier).send(argThat(triggerFiredBundleDTO -> { + Assertions.assertThat(triggerFiredBundleDTO.getJobKey()).isEqualTo("test-job"); + Assertions.assertThat(triggerFiredBundleDTO.getRepeatCount()).isEqualTo(6); + Assertions.assertThat(triggerFiredBundleDTO.getJobClass()).isEqualTo(SampleJob.class.getName()); + return true; + })); } @Test @@ -57,6 +68,7 @@ class SampleJobTest { LogRecord logRecord = sampleJob.doIt(jobExecutionContext); Assertions.assertThat(logRecord.getMessage()).isEqualTo("Hello!"); Assertions.assertThat(logRecord.getType()).isEqualTo(LogRecord.LogType.INFO); + Assertions.assertThat(logRecord.getDate()).isNotNull(); } }