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

Merge branch 'dev_2.0.1'

Browse Source
This commit is contained in:
byteblogs168 2023-07-09 17:55:46 +08:00
commit 574185449e
2 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

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

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 @Transactional
public void create(RetryTask retryTask) { public void create(RetryTask retryTask) {
if (!TaskTypeEnum.RETRY.getType().equals(retryTask.getTaskType())) {
return;
}
RetryTask callbackRetryTask = RetryTaskConverter.INSTANCE.toRetryTask(retryTask); RetryTask callbackRetryTask = RetryTaskConverter.INSTANCE.toRetryTask(retryTask);
callbackRetryTask.setTaskType(TaskTypeEnum.CALLBACK.getType()); callbackRetryTask.setTaskType(TaskTypeEnum.CALLBACK.getType());