do not throw exception from method processor

agorapulse · Jan 17, 2023 · b004cec · b004cec
1 parent a74468d
commit b004cec
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/libs/micronaut-worker/src/main/java/com/agorapulse/worker/processor/MethodJobProcessor.java b/libs/micronaut-worker/src/main/java/com/agorapulse/worker/processor/MethodJobProcessor.java
@@ -18,10 +18,12 @@
 package com.agorapulse.worker.processor;
 
 import com.agorapulse.worker.JobConfiguration;
+import com.agorapulse.worker.JobConfigurationException;
 import com.agorapulse.worker.JobManager;
 import com.agorapulse.worker.JobScheduler;
 import com.agorapulse.worker.WorkerConfiguration;
 import com.agorapulse.worker.annotation.*;
+import com.agorapulse.worker.annotation.Job;
 import com.agorapulse.worker.configuration.DefaultJobConfiguration;
 import com.agorapulse.worker.configuration.MutableJobConfiguration;
 import io.micronaut.context.ApplicationContext;
@@ -130,7 +132,11 @@ public void process(BeanDefinition<?> beanDefinition, ExecutableMethod<?, ?> met
             return;
         }
 
-        jobScheduler.schedule(task);
+        try {
+            jobScheduler.schedule(task);
+        } catch (JobConfigurationException e) {
+            LOG.error("Job declared in method " + method +  " is ignored because it is not correctly configured", e);
+        }
     }
 
     private String getJobName(BeanDefinition<?> beanDefinition, ExecutableMethod<?, ?> method) {