gtsoft/gtsoft-snail-job-demo
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

新增测试用例

Browse Source
This commit is contained in:
byteblogs168 2023-10-18 23:36:57 +08:00
parent 1a3224e0ad
commit db431e5565
2 changed files with 34 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
src/main/java/com/example/easy/retry/job/TestAnnoJobExecutor.java Normal file
View File

@ -0,0 +1,28 @@
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.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 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("测试成功");
}
}

19
src/main/java/com/example/easy/retry/job/TestJobExecutor.java
View File

@ -1,9 +1,8 @@
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.job.core.dto.JobArgs;
import com.aizuda.easy.retry.client.job.core.executor.AbstractJobExecutor;
import com.aizuda.easy.retry.client.model.ExecuteResult;
import com.aizuda.easy.retry.common.core.util.JsonUtil;
import org.springframework.stereotype.Component;
/**
@ -12,16 +11,10 @@ import org.springframework.stereotype.Component;
* @since 2.4.0
*/
@Component
@JobExecutor(name = "testJobExecutor")
public class TestJobExecutor {
public class TestJobExecutor extends AbstractJobExecutor {
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();
@Override
protected ExecuteResult doJobExecute(JobArgs jobArgs) {
return null;
}
}