🐛update processor

stelin · Jul 12, 2023 · 63da12c · 63da12c
1 parent 710344f
commit 63da12c
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 40 deletions.
diff --git a/...ker/openjob-worker-core/src/main/java/io/openjob/worker/processor/BroadcastProcessor.java b/...ker/openjob-worker-core/src/main/java/io/openjob/worker/processor/BroadcastProcessor.java
diff --git a/...ob-worker/openjob-worker-core/src/main/java/io/openjob/worker/processor/MapProcessor.java b/...ob-worker/openjob-worker-core/src/main/java/io/openjob/worker/processor/MapProcessor.java
@@ -20,7 +20,7 @@
  * @author stelin [email protected]
  * @since 1.0.0
  */
-public interface MapProcessor extends BaseProcessor {
+public interface MapProcessor extends JavaProcessor {
 
     /**
      * Map
@@ -61,14 +61,4 @@ default ProcessResult map(List<? extends Object> tasks, String taskName) {
         });
         return result;
     }
-
-    /**
-     * Stop processor.
-     *
-     * @param context context
-     */
-    @Override
-    default void stop(JobContext context) {
-
-    }
 }