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

测试1.4.0-beta1

Browse Source
This commit is contained in:
opensnail 2025-02-17 21:36:42 +08:00
parent 384007f7ff
commit 7e81fe9b73
4 changed files with 10 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
pom.xml
View File

@ -17,7 +17,7 @@
<properties> <properties>
<java.version>17</java.version> <java.version>17</java.version>
<snailjob.version>1.3.0-beta1.1</snailjob.version> <snailjob.version>1.4.0-beta1</snailjob.version>
</properties> </properties>
<dependencies> <dependencies>

12
src/main/java/com/example/snailjob/handler/TestAddJobHandler.java
View File

@ -3,7 +3,7 @@ package com.example.snailjob.handler;
import com.aizuda.snailjob.client.job.core.enums.AllocationAlgorithmEnum; import com.aizuda.snailjob.client.job.core.enums.AllocationAlgorithmEnum;
import com.aizuda.snailjob.client.job.core.enums.TriggerTypeEnum; import com.aizuda.snailjob.client.job.core.enums.TriggerTypeEnum;
import com.aizuda.snailjob.client.job.core.openapi.SnailJobOpenApi; import com.aizuda.snailjob.client.job.core.openapi.SnailJobOpenApi;
import com.aizuda.snailjob.common.core.enums.BlockStrategyEnum; import com.aizuda.snailjob.common.core.enums.JobBlockStrategyEnum;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
@Component @Component
@ -22,7 +22,7 @@ public class TestAddJobHandler {
.setExecutorInfo("testJobExecutor") .setExecutorInfo("testJobExecutor")
.setExecutorTimeout(30) .setExecutorTimeout(30)
.setDescription("add") .setDescription("add")
.setBlockStrategy(BlockStrategyEnum.DISCARD) .setBlockStrategy(JobBlockStrategyEnum.DISCARD)
.setMaxRetryTimes(1) .setMaxRetryTimes(1)
.setTriggerType(TriggerTypeEnum.SCHEDULED_TIME) .setTriggerType(TriggerTypeEnum.SCHEDULED_TIME)
.setTriggerInterval(String.valueOf(60)) .setTriggerInterval(String.valueOf(60))
@ -45,7 +45,7 @@ public class TestAddJobHandler {
.setExecutorInfo("testJobExecutor") .setExecutorInfo("testJobExecutor")
.setExecutorTimeout(30) .setExecutorTimeout(30)
.setDescription("add") .setDescription("add")
.setBlockStrategy(BlockStrategyEnum.DISCARD) .setBlockStrategy(JobBlockStrategyEnum.DISCARD)
.setMaxRetryTimes(1) .setMaxRetryTimes(1)
.setTriggerType(TriggerTypeEnum.CRON) .setTriggerType(TriggerTypeEnum.CRON)
.setTriggerInterval("afas") .setTriggerInterval("afas")
@ -68,7 +68,7 @@ public class TestAddJobHandler {
.setExecutorInfo("testJobExecutor") .setExecutorInfo("testJobExecutor")
.setExecutorTimeout(30) .setExecutorTimeout(30)
.setDescription("add") .setDescription("add")
.setBlockStrategy(BlockStrategyEnum.DISCARD) .setBlockStrategy(JobBlockStrategyEnum.DISCARD)
.setMaxRetryTimes(1) .setMaxRetryTimes(1)
.setTriggerType(TriggerTypeEnum.SCHEDULED_TIME) .setTriggerType(TriggerTypeEnum.SCHEDULED_TIME)
.setTriggerInterval(60) .setTriggerInterval(60)
@ -91,7 +91,7 @@ public class TestAddJobHandler {
.setExecutorInfo("testJobExecutor") .setExecutorInfo("testJobExecutor")
.setExecutorTimeout(30) .setExecutorTimeout(30)
.setDescription("add") .setDescription("add")
.setBlockStrategy(BlockStrategyEnum.DISCARD) .setBlockStrategy(JobBlockStrategyEnum.DISCARD)
.setMaxRetryTimes(1) .setMaxRetryTimes(1)
.setTriggerType(TriggerTypeEnum.SCHEDULED_TIME) .setTriggerType(TriggerTypeEnum.SCHEDULED_TIME)
.setTriggerInterval(String.valueOf(60)) .setTriggerInterval(String.valueOf(60))
@ -113,7 +113,7 @@ public class TestAddJobHandler {
.setExecutorInfo("testJobExecutor") .setExecutorInfo("testJobExecutor")
.setExecutorTimeout(30) .setExecutorTimeout(30)
.setDescription("add") .setDescription("add")
.setBlockStrategy(BlockStrategyEnum.DISCARD) .setBlockStrategy(JobBlockStrategyEnum.DISCARD)
.setMaxRetryTimes(1) .setMaxRetryTimes(1)
.setTriggerType(TriggerTypeEnum.SCHEDULED_TIME) .setTriggerType(TriggerTypeEnum.SCHEDULED_TIME)
.setTriggerInterval(String.valueOf(60)) .setTriggerInterval(String.valueOf(60))

4
src/main/java/com/example/snailjob/handler/TestTriggerJobHandler.java
View File

@ -12,8 +12,8 @@ public class TestTriggerJobHandler {
* @param jobId 任务ID * @param jobId 任务ID
* @return * @return
*/ */
public Boolean triggerJob(Long jobId){ public Boolean triggerJob(Long jobId) {
return SnailJobOpenApi.triggerJob(jobId).execute(); return SnailJobOpenApi.triggerClusterJob(jobId).execute();
} }
/** /**

2
src/main/resources/application.yml
View File

@ -57,4 +57,4 @@ snail-job:
host: 127.0.0.1 host: 127.0.0.1
# 客户端通讯端口，默认 1789 # 客户端通讯端口，默认 1789
port: 17889 port: 17889
rpc-type: netty rpc-type: grpc