feature: 原子操作能力支持滚动执行 TencentBlueKing#446

定义web API
wangyu096 · Jan 4, 2022 · f22b14a · f22b14a
1 parent 06f34af
commit f22b14a
Show file tree

Hide file tree

Showing 4 changed files with 442 additions and 3 deletions.
diff --git a/...execute/engine/listener/TaskListener.java → .../execute/engine/listener/JobListener.java b/...execute/engine/listener/TaskListener.java → .../execute/engine/listener/JobListener.java
@@ -57,15 +57,16 @@
 @Component
 @EnableBinding({TaskProcessor.class})
 @Slf4j
-public class TaskListener {
+public class JobListener {
 
     private final TaskExecuteControlMsgSender taskExecuteControlMsgSender;
     private final StatisticsService statisticsService;
     private final TaskInstanceService taskInstanceService;
 
     @Autowired
-    public TaskListener(TaskExecuteControlMsgSender taskExecuteControlMsgSender,
-                        StatisticsService statisticsService, TaskInstanceService taskInstanceService) {
+    public JobListener(TaskExecuteControlMsgSender taskExecuteControlMsgSender,
+                       StatisticsService statisticsService,
+                       TaskInstanceService taskInstanceService) {
         this.taskExecuteControlMsgSender = taskExecuteControlMsgSender;
         this.statisticsService = statisticsService;
         this.taskInstanceService = taskInstanceService;