From 7e81fe9b738c0c308ac639584e99330eadd5bdae Mon Sep 17 00:00:00 2001
From: opensnail <598092184@qq.com>
Date: Mon, 17 Feb 2025 21:36:42 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B5=8B=E8=AF=951.4.0-beta1?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 pom.xml                                              |  2 +-
 .../example/snailjob/handler/TestAddJobHandler.java  | 12 ++++++------
 .../snailjob/handler/TestTriggerJobHandler.java      |  4 ++--
 src/main/resources/application.yml                   |  2 +-
 4 files changed, 10 insertions(+), 10 deletions(-)

diff --git a/pom.xml b/pom.xml
index 69dfad1..92faed4 100644
--- a/pom.xml
+++ b/pom.xml
@@ -17,7 +17,7 @@
 
     <properties>
         <java.version>17</java.version>
-        <snailjob.version>1.3.0-beta1.1</snailjob.version>
+        <snailjob.version>1.4.0-beta1</snailjob.version>
     </properties>
 
     <dependencies>
diff --git a/src/main/java/com/example/snailjob/handler/TestAddJobHandler.java b/src/main/java/com/example/snailjob/handler/TestAddJobHandler.java
index 8f184f4..10d0858 100644
--- a/src/main/java/com/example/snailjob/handler/TestAddJobHandler.java
+++ b/src/main/java/com/example/snailjob/handler/TestAddJobHandler.java
@@ -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.TriggerTypeEnum;
 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;
 
 @Component
@@ -22,7 +22,7 @@ public class TestAddJobHandler {
                 .setExecutorInfo("testJobExecutor")
                 .setExecutorTimeout(30)
                 .setDescription("add")
-                .setBlockStrategy(BlockStrategyEnum.DISCARD)
+                .setBlockStrategy(JobBlockStrategyEnum.DISCARD)
                 .setMaxRetryTimes(1)
                 .setTriggerType(TriggerTypeEnum.SCHEDULED_TIME)
                 .setTriggerInterval(String.valueOf(60))
@@ -45,7 +45,7 @@ public class TestAddJobHandler {
                 .setExecutorInfo("testJobExecutor")
                 .setExecutorTimeout(30)
                 .setDescription("add")
-                .setBlockStrategy(BlockStrategyEnum.DISCARD)
+                .setBlockStrategy(JobBlockStrategyEnum.DISCARD)
                 .setMaxRetryTimes(1)
                 .setTriggerType(TriggerTypeEnum.CRON)
                 .setTriggerInterval("afas")
@@ -68,7 +68,7 @@ public class TestAddJobHandler {
                 .setExecutorInfo("testJobExecutor")
                 .setExecutorTimeout(30)
                 .setDescription("add")
-                .setBlockStrategy(BlockStrategyEnum.DISCARD)
+                .setBlockStrategy(JobBlockStrategyEnum.DISCARD)
                 .setMaxRetryTimes(1)
                 .setTriggerType(TriggerTypeEnum.SCHEDULED_TIME)
                 .setTriggerInterval(60)
@@ -91,7 +91,7 @@ public class TestAddJobHandler {
                 .setExecutorInfo("testJobExecutor")
                 .setExecutorTimeout(30)
                 .setDescription("add")
-                .setBlockStrategy(BlockStrategyEnum.DISCARD)
+                .setBlockStrategy(JobBlockStrategyEnum.DISCARD)
                 .setMaxRetryTimes(1)
                 .setTriggerType(TriggerTypeEnum.SCHEDULED_TIME)
                 .setTriggerInterval(String.valueOf(60))
@@ -113,7 +113,7 @@ public class TestAddJobHandler {
                 .setExecutorInfo("testJobExecutor")
                 .setExecutorTimeout(30)
                 .setDescription("add")
-                .setBlockStrategy(BlockStrategyEnum.DISCARD)
+                .setBlockStrategy(JobBlockStrategyEnum.DISCARD)
                 .setMaxRetryTimes(1)
                 .setTriggerType(TriggerTypeEnum.SCHEDULED_TIME)
                 .setTriggerInterval(String.valueOf(60))
diff --git a/src/main/java/com/example/snailjob/handler/TestTriggerJobHandler.java b/src/main/java/com/example/snailjob/handler/TestTriggerJobHandler.java
index 1d22f47..4f7f432 100644
--- a/src/main/java/com/example/snailjob/handler/TestTriggerJobHandler.java
+++ b/src/main/java/com/example/snailjob/handler/TestTriggerJobHandler.java
@@ -12,8 +12,8 @@ public class TestTriggerJobHandler {
      * @param jobId 任务ID
      * @return
      */
-    public Boolean triggerJob(Long jobId){
-        return SnailJobOpenApi.triggerJob(jobId).execute();
+    public Boolean triggerJob(Long jobId) {
+        return SnailJobOpenApi.triggerClusterJob(jobId).execute();
     }
 
     /**
diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml
index 254597b..5d082ec 100644
--- a/src/main/resources/application.yml
+++ b/src/main/resources/application.yml
@@ -57,4 +57,4 @@ snail-job:
   host: 127.0.0.1
   # 客户端通讯端口，默认 1789
   port: 17889
-  rpc-type: netty
+  rpc-type: grpc