diff --git a/src/main/java/com/example/easy/retry/job/TestAnnoJobExecutor.java b/src/main/java/com/example/easy/retry/job/TestAnnoJobExecutor.java index 2629d85..1309ea3 100644 --- a/src/main/java/com/example/easy/retry/job/TestAnnoJobExecutor.java +++ b/src/main/java/com/example/easy/retry/job/TestAnnoJobExecutor.java @@ -17,12 +17,6 @@ import org.springframework.stereotype.Component; public class TestAnnoJobExecutor { public ExecuteResult jobExecute(JobArgs jobArgs) { - System.out.println(JsonUtil.toJsonString(jobArgs)); -// try { -// Thread.sleep(30 * 1000); -// } catch (InterruptedException e) { -// throw new RuntimeException(e); -// } return ExecuteResult.success("测试成功"); } } diff --git a/src/main/java/com/example/easy/retry/job/TestAnnoJobExecutorSleep10s.java b/src/main/java/com/example/easy/retry/job/TestAnnoJobExecutorSleep10s.java new file mode 100644 index 0000000..5e7a327 --- /dev/null +++ b/src/main/java/com/example/easy/retry/job/TestAnnoJobExecutorSleep10s.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.JobArgs; +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 = "testAnnoJobExecutorSleep10s") +public class TestAnnoJobExecutorSleep10s { + + public ExecuteResult jobExecute(JobArgs jobArgs) { + System.out.println(JsonUtil.toJsonString(jobArgs)); + try { + Thread.sleep(10 * 1000); + } catch (InterruptedException e) { + throw new RuntimeException(e); + } + return ExecuteResult.success("测试成功"); + } +} diff --git a/src/main/java/com/example/easy/retry/job/TestAnnoJobExecutorSleep1s.java b/src/main/java/com/example/easy/retry/job/TestAnnoJobExecutorSleep1s.java new file mode 100644 index 0000000..00e0de9 --- /dev/null +++ b/src/main/java/com/example/easy/retry/job/TestAnnoJobExecutorSleep1s.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.JobArgs; +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 = "testAnnoJobExecutorSleep1s") +public class TestAnnoJobExecutorSleep1s { + + public ExecuteResult jobExecute(JobArgs jobArgs) { + System.out.println(JsonUtil.toJsonString(jobArgs)); + try { + Thread.sleep(1000); + } catch (InterruptedException e) { + throw new RuntimeException(e); + } + return ExecuteResult.success("测试成功"); + } +} diff --git a/src/main/java/com/example/easy/retry/job/TestAnnoJobExecutorSleep30s.java b/src/main/java/com/example/easy/retry/job/TestAnnoJobExecutorSleep30s.java new file mode 100644 index 0000000..14f3591 --- /dev/null +++ b/src/main/java/com/example/easy/retry/job/TestAnnoJobExecutorSleep30s.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.JobArgs; +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 = "testAnnoJobExecutorSleep30s") +public class TestAnnoJobExecutorSleep30s { + + public ExecuteResult jobExecute(JobArgs jobArgs) { + System.out.println(JsonUtil.toJsonString(jobArgs)); + try { + Thread.sleep(30 * 1000); + } catch (InterruptedException e) { + throw new RuntimeException(e); + } + return ExecuteResult.success("测试成功"); + } +} diff --git a/src/main/java/com/example/easy/retry/job/TestAnnoJobExecutorSleep5s.java b/src/main/java/com/example/easy/retry/job/TestAnnoJobExecutorSleep5s.java new file mode 100644 index 0000000..46fea0f --- /dev/null +++ b/src/main/java/com/example/easy/retry/job/TestAnnoJobExecutorSleep5s.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.JobArgs; +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 = "testAnnoJobExecutorSleep5s") +public class TestAnnoJobExecutorSleep5s { + + public ExecuteResult jobExecute(JobArgs jobArgs) { + System.out.println(JsonUtil.toJsonString(jobArgs)); + try { + Thread.sleep(5 * 1000); + } catch (InterruptedException e) { + throw new RuntimeException(e); + } + return ExecuteResult.success("测试成功"); + } +} diff --git a/src/main/java/com/example/easy/retry/job/TestJobExecutor.java b/src/main/java/com/example/easy/retry/job/TestClassJobExecutor.java similarity index 77% rename from src/main/java/com/example/easy/retry/job/TestJobExecutor.java rename to src/main/java/com/example/easy/retry/job/TestClassJobExecutor.java index 62c125d..4029b73 100644 --- a/src/main/java/com/example/easy/retry/job/TestJobExecutor.java +++ b/src/main/java/com/example/easy/retry/job/TestClassJobExecutor.java @@ -11,10 +11,10 @@ import org.springframework.stereotype.Component; * @since 2.4.0 */ @Component -public class TestJobExecutor extends AbstractJobExecutor { +public class TestClassJobExecutor extends AbstractJobExecutor { @Override protected ExecuteResult doJobExecute(JobArgs jobArgs) { - return null; + return ExecuteResult.success("TestJobExecutor测试成功"); } }