From 4cce228d5c558b484229185d9ab90c3c3351d5ba Mon Sep 17 00:00:00 2001 From: byteblogs168 <598092184@qq.com> Date: Thu, 22 Feb 2024 23:10:31 +0800 Subject: [PATCH] =?UTF-8?q?feat:=203.1.0=201.=20=E6=B7=BB=E5=8A=A0?= =?UTF-8?q?=E9=87=8D=E8=AF=95=E4=BC=A0=E6=92=AD=E6=9C=BA=E5=88=B6=E7=9A=84?= =?UTF-8?q?=E6=8F=8F=E8=BF=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../retry/client/core/annotation/Propagation.java | 11 +++++++++++ .../web/service/impl/WorkflowNodeServiceImpl.java | 3 +++ 2 files changed, 14 insertions(+) diff --git a/easy-retry-client/easy-retry-client-core/src/main/java/com/aizuda/easy/retry/client/core/annotation/Propagation.java b/easy-retry-client/easy-retry-client-core/src/main/java/com/aizuda/easy/retry/client/core/annotation/Propagation.java index e4cc0eba..cd38cce2 100644 --- a/easy-retry-client/easy-retry-client-core/src/main/java/com/aizuda/easy/retry/client/core/annotation/Propagation.java +++ b/easy-retry-client/easy-retry-client-core/src/main/java/com/aizuda/easy/retry/client/core/annotation/Propagation.java @@ -1,13 +1,24 @@ package com.aizuda.easy.retry.client.core.annotation; /** + * Easy Retry 重试任务传播机制 + * * @author: xiaowoniu * @date : 2024-02-05 * @since : 3.1.0 */ public enum Propagation { + /** + * 当设置为REQUIRED时,如果当前重试存在,就加入到当前重试中,即外部入口触发重试 + * 如果当前重试不存在,就创建一个新的重试任务。 + */ REQUIRED, + + /** + * 当设置为REQUIRES_NEW时, + * 无论当前重试任务是否存在,都会一个新的重试任务。 + */ REQUIRES_NEW ; diff --git a/easy-retry-server/easy-retry-server-web/src/main/java/com/aizuda/easy/retry/server/web/service/impl/WorkflowNodeServiceImpl.java b/easy-retry-server/easy-retry-server-web/src/main/java/com/aizuda/easy/retry/server/web/service/impl/WorkflowNodeServiceImpl.java index 50378b16..d94cdedb 100644 --- a/easy-retry-server/easy-retry-server-web/src/main/java/com/aizuda/easy/retry/server/web/service/impl/WorkflowNodeServiceImpl.java +++ b/easy-retry-server/easy-retry-server-web/src/main/java/com/aizuda/easy/retry/server/web/service/impl/WorkflowNodeServiceImpl.java @@ -10,8 +10,11 @@ import org.springframework.stereotype.Service; */ @Service public class WorkflowNodeServiceImpl implements WorkflowNodeService { + @Override public Boolean stop(Long id) { + // 调用JOB的停止接口 + // 继续执行后续的任务 return null; }