新增BizNo 表达式的测试

This commit is contained in:
byteblogs168 2023-10-06 22:59:34 +08:00
parent b00729148d
commit 1a3224e0ad
2 changed files with 42 additions and 0 deletions

15
pom.xml
View File

@ -40,6 +40,21 @@
<artifactId>easy-retry-client-starter</artifactId>
<version>2.4.0-SNAPSHOT</version>
</dependency>
<dependency>
<groupId>com.aizuda</groupId>
<artifactId>easy-retry-client-core</artifactId>
<version>2.4.0-SNAPSHOT</version>
</dependency>
<dependency>
<groupId>com.aizuda</groupId>
<artifactId>easy-retry-client-job-core</artifactId>
<version>2.4.0-SNAPSHOT</version>
</dependency>
<dependency>
<groupId>org.freemarker</groupId>
<artifactId>freemarker</artifactId>
<version>2.3.28</version>
</dependency>
<dependency>
<groupId>com.googlecode.aviator</groupId>
<artifactId>aviator</artifactId>

View File

@ -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();
}
}