From 6946f24172deb373bf6d37a6abce9cdbe57ffaec Mon Sep 17 00:00:00 2001
From: byteblogs168 <598092184@qq.com>
Date: Sun, 9 Jul 2023 12:57:45 +0800
Subject: [PATCH] =?UTF-8?q?feat:=202.0.1=20=E4=BF=AE=E5=A4=8D=E5=9B=9E?=
 =?UTF-8?q?=E8=B0=83=E4=BB=BB=E5=8A=A1=E6=89=A7=E8=A1=8C=E5=88=B0=E8=BE=BE?=
 =?UTF-8?q?=E6=9C=80=E5=A4=A7=E6=AC=A1=E6=95=B0=E5=90=8E=E9=87=8D=E5=A4=8D?=
 =?UTF-8?q?=E6=96=B0=E5=BB=BA=E5=9B=9E=E8=B0=83=E4=BB=BB=E5=8A=A1?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../server/support/dispatch/actor/result/FinishActor.java   | 6 ++----
 .../server/support/handler/CallbackRetryTaskHandler.java    | 4 ++++
 2 files changed, 6 insertions(+), 4 deletions(-)

diff --git a/easy-retry-server/src/main/java/com/aizuda/easy/retry/server/support/dispatch/actor/result/FinishActor.java b/easy-retry-server/src/main/java/com/aizuda/easy/retry/server/support/dispatch/actor/result/FinishActor.java
index 275d82906..14fafb1ef 100644
--- a/easy-retry-server/src/main/java/com/aizuda/easy/retry/server/support/dispatch/actor/result/FinishActor.java
+++ b/easy-retry-server/src/main/java/com/aizuda/easy/retry/server/support/dispatch/actor/result/FinishActor.java
@@ -57,10 +57,8 @@ public class FinishActor extends AbstractActor  {
                    protected void doInTransactionWithoutResult(TransactionStatus status) {
                        retryTaskAccess.updateRetryTask(retryTask);
 
-                       if (TaskTypeEnum.RETRY.getType().equals(retryTask.getTaskType())) {
-                           // 创建一个回调任务
-                           callbackRetryTaskHandler.create(retryTask);
-                       }
+                       // 创建一个回调任务
+                       callbackRetryTaskHandler.create(retryTask);
                    }
                });
 
diff --git a/easy-retry-server/src/main/java/com/aizuda/easy/retry/server/support/handler/CallbackRetryTaskHandler.java b/easy-retry-server/src/main/java/com/aizuda/easy/retry/server/support/handler/CallbackRetryTaskHandler.java
index c35e31aa5..37de552eb 100644
--- a/easy-retry-server/src/main/java/com/aizuda/easy/retry/server/support/handler/CallbackRetryTaskHandler.java
+++ b/easy-retry-server/src/main/java/com/aizuda/easy/retry/server/support/handler/CallbackRetryTaskHandler.java
@@ -40,6 +40,10 @@ public class CallbackRetryTaskHandler {
 
     @Transactional
     public void create(RetryTask retryTask) {
+        if (!TaskTypeEnum.RETRY.getType().equals(retryTask.getTaskType())) {
+          return;
+        }
+
         RetryTask callbackRetryTask = RetryTaskConverter.INSTANCE.toRetryTask(retryTask);
 
         callbackRetryTask.setTaskType(TaskTypeEnum.CALLBACK.getType());