From 293211a5b2d487f3a685e4d2ed8c27c52eabfa41 Mon Sep 17 00:00:00 2001 From: musketyr Date: Tue, 10 Dec 2024 13:20:59 +0100 Subject: [PATCH] print invalid configuration --- .../configuration/DefaultJobConfiguration.java | 17 +++++++++++++++++ .../worker/schedule/DefaultJobScheduler.java | 2 +- 2 files changed, 18 insertions(+), 1 deletion(-) diff --git a/libs/micronaut-worker/src/main/java/com/agorapulse/worker/configuration/DefaultJobConfiguration.java b/libs/micronaut-worker/src/main/java/com/agorapulse/worker/configuration/DefaultJobConfiguration.java index 7390ea94..db72b3d7 100644 --- a/libs/micronaut-worker/src/main/java/com/agorapulse/worker/configuration/DefaultJobConfiguration.java +++ b/libs/micronaut-worker/src/main/java/com/agorapulse/worker/configuration/DefaultJobConfiguration.java @@ -75,6 +75,11 @@ public void mergeWith(QueueConfiguration overrides) { this.queueType = overrides.getQueueType(); } } + + @Override + public String toString() { + return "DefaultQueueConfiguration{queueName='%s', queueType='%s'}".formatted(queueName, queueType); + } } @JsonInclude @@ -118,6 +123,12 @@ public void mergeWith(ConsumerQueueConfiguration overrides) { this.waitingTime = overrides.getWaitingTime(); } } + + @Override + public String toString() { + return "DefaultConsumerQueueConfiguration{queueName='%s', queueType='%s', maxMessages=%d, waitingTime=%s}" + .formatted(getQueueName(), getQueueType(), maxMessages, waitingTime); + } } private final String name; @@ -337,4 +348,10 @@ public JobConfiguration mergeWith(JobConfiguration overrides) { return this; } + + @Override + public String toString() { + return "DefaultJobConfiguration{name='%s', enabled=%s, concurrency=%d, leaderOnly=%s, followerOnly=%s, cron='%s', fixedDelay=%s, initialDelay=%s, fixedRate=%s, scheduler='%s', fork=%d, consumer=%s, producer=%s}" + .formatted(name, enabled, concurrency, leaderOnly, followerOnly, cron, fixedDelay, initialDelay, fixedRate, scheduler, fork, consumer, producer); + } } diff --git a/libs/micronaut-worker/src/main/java/com/agorapulse/worker/schedule/DefaultJobScheduler.java b/libs/micronaut-worker/src/main/java/com/agorapulse/worker/schedule/DefaultJobScheduler.java index 43333c58..8066ffb3 100644 --- a/libs/micronaut-worker/src/main/java/com/agorapulse/worker/schedule/DefaultJobScheduler.java +++ b/libs/micronaut-worker/src/main/java/com/agorapulse/worker/schedule/DefaultJobScheduler.java @@ -126,7 +126,7 @@ private ScheduledFuture doSchedule(Job job, JobConfiguration configuration, T return taskScheduler.schedule(initialDelay, job); } - throw new JobConfigurationException(job, "Failed to schedule job " + configuration.getName() + " declared in " + job.getSource() + ". Invalid definition"); + throw new JobConfigurationException(job, "Failed to schedule job " + configuration.getName() + " declared in " + job.getSource() + ". Invalid definition: " + configuration); } private TaskScheduler getTaskScheduler(com.agorapulse.worker.Job job) {