Update JobQueueHelper.java

dotCMS · Nov 19, 2024 · ea4fa2e · ea4fa2e
1 parent c6e620f
commit ea4fa2e
Showing 1 changed file with 10 additions and 0 deletions.
diff --git a/dotCMS/src/main/java/com/dotcms/rest/api/v1/job/JobQueueHelper.java b/dotCMS/src/main/java/com/dotcms/rest/api/v1/job/JobQueueHelper.java
@@ -69,6 +69,16 @@ void registerProcessor(final String queueName, final Class<? extends JobProcesso
         jobQueueManagerAPI.registerProcessor(queueName, processor);
     }
 
+    @PostConstruct
+    public void onInit() {
+        jobQueueManagerHelper.registerProcessors(jobQueueManagerAPI);
+    }
+
+    @PreDestroy
+    public void onDestroy() {
+        jobQueueManagerHelper.shutdown(jobQueueManagerAPI);
+    }
+
     /**
      * Creates a job
      *