From 1a3224e0adbbdc6836d524650d11db496dd81090 Mon Sep 17 00:00:00 2001 From: byteblogs168 <598092184@qq.com> Date: Fri, 6 Oct 2023 22:59:34 +0800 Subject: [PATCH] =?UTF-8?q?=E6=96=B0=E5=A2=9EBizNo=20=E8=A1=A8=E8=BE=BE?= =?UTF-8?q?=E5=BC=8F=E7=9A=84=E6=B5=8B=E8=AF=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- pom.xml | 15 +++++++++++ .../easy/retry/job/TestJobExecutor.java | 27 +++++++++++++++++++ 2 files changed, 42 insertions(+) create mode 100644 src/main/java/com/example/easy/retry/job/TestJobExecutor.java diff --git a/pom.xml b/pom.xml index c68a071..1b68cc3 100644 --- a/pom.xml +++ b/pom.xml @@ -40,6 +40,21 @@ easy-retry-client-starter 2.4.0-SNAPSHOT + + com.aizuda + easy-retry-client-core + 2.4.0-SNAPSHOT + + + com.aizuda + easy-retry-client-job-core + 2.4.0-SNAPSHOT + + + org.freemarker + freemarker + 2.3.28 + com.googlecode.aviator aviator diff --git a/src/main/java/com/example/easy/retry/job/TestJobExecutor.java b/src/main/java/com/example/easy/retry/job/TestJobExecutor.java new file mode 100644 index 0000000..210fdaf --- /dev/null +++ b/src/main/java/com/example/easy/retry/job/TestJobExecutor.java @@ -0,0 +1,27 @@ +package com.example.easy.retry.job; + +import com.aizuda.easy.retry.client.job.core.annotation.JobExecutor; +import com.aizuda.easy.retry.client.job.core.dto.JobContext; +import com.aizuda.easy.retry.client.model.ExecuteResult; +import com.aizuda.easy.retry.common.core.util.JsonUtil; +import org.springframework.stereotype.Component; + +/** + * @author www.byteblogs.com + * @date 2023-09-28 22:54:07 + * @since 2.4.0 + */ +@Component +@JobExecutor(name = "testJobExecutor") +public class TestJobExecutor { + + public ExecuteResult jobExecute(JobContext context) { + System.out.println(JsonUtil.toJsonString(context)); + try { + Thread.sleep(30 * 1000); + } catch (InterruptedException e) { + throw new RuntimeException(e); + } + return ExecuteResult.success(); + } +}