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; }