wangli/workflow-engine
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

update - 解决多个任务同时操作同一个实例,出现的事务问题

Browse Source
This commit is contained in:
wangli 2024-07-03 11:04:54 +08:00
parent 5d33094266
commit 1065db0f6f
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
workflow-engine-core/src/main/java/cn/axzo/workflow/core/engine/interceptor/CustomRetryInterceptor.java
View File

@ -53,10 +53,11 @@ public class CustomRetryInterceptor extends AbstractCommandInterceptor {
failedAttempts++; failedAttempts++;
} while (failedAttempts <= numOfRetries); } while (failedAttempts <= numOfRetries);
throw new WorkflowEngineException(ENGINE_ASYNC_COMMAND_EXECUTION_RETRY_GIVE_UP, String.valueOf(numOfRetries));
} catch (Throwable e) { } catch (Throwable e) {
log.error("Caught exception: {}", e.getMessage(), e);
throw new WorkflowEngineException(ENGINE_ASYNC_COMMAND_EXECUTION_ERROR, e.getMessage()); throw new WorkflowEngineException(ENGINE_ASYNC_COMMAND_EXECUTION_ERROR, e.getMessage());
} }
throw new WorkflowEngineException(ENGINE_ASYNC_COMMAND_EXECUTION_RETRY_GIVE_UP, String.valueOf(numOfRetries));
} }
protected void waitBeforeRetry(long waitTime) { protected void waitBeforeRetry(long waitTime) {