::lipstick:

Author: stelin

openjob-server/openjob-server-repository/src/main/java/io/openjob/server/repository/repository/DelayInstanceRepository.java

@@ -37,7 +37,8 @@ public interface DelayInstanceRepository extends JpaRepository<DelayInstance, Lo
      * @param deleted  deleted
      * @return List
      */
-    @Query(value = "SELECT new io.openjob.server.repository.dto.DelayInstanceTotalDTO(d.topic, count(d.id)) from DelayInstance as d where d.topic in (?1) and d.status in (?2) and d.deleted=?3 group by d.topic")
+    @Query(value = "SELECT new io.openjob.server.repository.dto.DelayInstanceTotalDTO(d.topic, count(d.id)) from DelayInstance as d "
+            + "where d.topic in (?1) and d.status in (?2) and d.deleted=?3 group by d.topic")
     List<DelayInstanceTotalDTO> getDelayTotalCount(List<String> topics, List<Integer> statuses, Integer deleted);
 
     /**
@@ -49,6 +50,8 @@ public interface DelayInstanceRepository extends JpaRepository<DelayInstance, Lo
     DelayInstance findByTaskId(String taskId);
 
     /**
+     * Update status by task id
+     *
      * @param taskId taskId
      * @param status status
      * @return Integer

openjob-worker/openjob-worker-core/src/main/java/io/openjob/worker/OpenjobWorker.java

@@ -82,6 +82,11 @@ public synchronized void init() throws Exception {
         }, 0, retryInterval, TimeUnit.SECONDS);
     }
 
+    /**
+     * Do initialize
+     *
+     * @return Boolean
+     */
     public synchronized Boolean doInitialize() {
         try {
             // Initialize worker config.

openjob-worker/openjob-worker-core/src/main/java/io/openjob/worker/init/WorkerShutdown.java

@@ -26,6 +26,9 @@ public WorkerShutdown(OpenjobWorker openjobWorker) {
         this.openjobWorker = openjobWorker;
     }
 
+    /**
+     * Init
+     */
     public void init() {
         // Already initialized
         if (this.isInit.get()) {