fix(quartz): ensure that invoker is properly initialized in QuartzJob…

…Definition#schedule (cherry picked from commit e29869d)
quarkusio · May 23, 2023 · c8d802b · c8d802b
1 parent eef9bc5
commit c8d802b
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/extensions/quartz/runtime/src/main/java/io/quarkus/quartz/runtime/QuartzSchedulerImpl.java b/extensions/quartz/runtime/src/main/java/io/quarkus/quartz/runtime/QuartzSchedulerImpl.java
@@ -807,6 +807,8 @@ public boolean isBlocking() {
             Optional<TriggerBuilder<?>> triggerBuilder = createTrigger(identity, scheduled, cronType, runtimeConfig, jobDetail);
 
             if (triggerBuilder.isPresent()) {
+                invoker = SimpleScheduler.initInvoker(invoker, skippedExecutionEvent, successExecutionEvent,
+                        failedExecutionEvent, concurrentExecution, skipPredicate);
                 org.quartz.Trigger trigger = triggerBuilder.get().build();
                 QuartzTrigger existing = scheduledTasks.putIfAbsent(identity, new QuartzTrigger(trigger.getKey(),
                         new Function<>() {
@@ -826,8 +828,6 @@ public org.quartz.Trigger apply(TriggerKey triggerKey) {
                     throw new IllegalStateException("A job with this identity is already scheduled: " + identity);
                 }
 
-                invoker = SimpleScheduler.initInvoker(invoker, skippedExecutionEvent, successExecutionEvent,
-                        failedExecutionEvent, concurrentExecution, skipPredicate);
                 try {
                     scheduler.scheduleJob(jobDetail, trigger);
                 } catch (SchedulerException e) {