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

feat: 2.0.1

Browse Source 
修复回调任务执行到达最大次数后重复新建回调任务
This commit is contained in:
byteblogs168 2023-07-09 12:57:45 +08:00
parent 3649d7ae33
commit 6946f24172
2 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
easy-retry-server/src/main/java/com/aizuda/easy/retry/server/support/dispatch/actor/result/FinishActor.java
View File

@ -57,11 +57,9 @@ public class FinishActor extends AbstractActor {
protected void doInTransactionWithoutResult(TransactionStatus status) {
retryTaskAccess.updateRetryTask(retryTask);
if (TaskTypeEnum.RETRY.getType().equals(retryTask.getTaskType())) {
// 创建一个回调任务
callbackRetryTaskHandler.create(retryTask);
}
}
});
}catch (Exception e) {

4
easy-retry-server/src/main/java/com/aizuda/easy/retry/server/support/handler/CallbackRetryTaskHandler.java
View File

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