public/liteFlow
1
0
Fork 0
mirror of https://gitee.com/dromara/liteFlow.git synced 2026-05-14 20:22:07 +08:00
Code Issues Packages Projects Releases Wiki Activity

1.调整执行器用例

Browse Source 
2.调整执行器class初始化位置
This commit is contained in:
sikadai
2022-02-10 18:15:00 +08:00
parent 5c4f26f00c
commit c513da7314
2 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
liteflow-core/src/main/java/com/yomahub/liteflow/core/ComponentInitializer.java
View File

@@ -47,14 +47,14 @@ public class ComponentInitializer {
//先从组件上取@RetryCount标注，如果没有，则看全局配置，全局配置如果不配置的话，默认是0 //先从组件上取@RetryCount标注，如果没有，则看全局配置，全局配置如果不配置的话，默认是0
//默认retryForExceptions为Exception.class //默认retryForExceptions为Exception.class
LiteflowRetry liteflowRetryAnnotation = AnnotationUtils.getAnnotation(nodeComponent.getClass(), LiteflowRetry.class); LiteflowRetry liteflowRetryAnnotation = AnnotationUtils.getAnnotation(nodeComponent.getClass(), LiteflowRetry.class);
LiteflowConfig liteflowConfig = LiteflowConfigGetter.get();
if (ObjectUtil.isNotNull(liteflowRetryAnnotation)) { if (ObjectUtil.isNotNull(liteflowRetryAnnotation)) {
nodeComponent.setRetryCount(liteflowRetryAnnotation.retry()); nodeComponent.setRetryCount(liteflowRetryAnnotation.retry());
nodeComponent.setRetryForExceptions(liteflowRetryAnnotation.forExceptions()); nodeComponent.setRetryForExceptions(liteflowRetryAnnotation.forExceptions());
} else { } else {
LiteflowConfig liteflowConfig = LiteflowConfigGetter.get();
nodeComponent.setRetryCount(liteflowConfig.getRetryCount()); nodeComponent.setRetryCount(liteflowConfig.getRetryCount());
nodeComponent.setNodeExecutorClass(liteflowConfig.getNodeExecutorClass());
} }
nodeComponent.setNodeExecutorClass(liteflowConfig.getNodeExecutorClass());
return nodeComponent; return nodeComponent;
} }

2
liteflow-testcase-springboot/src/test/resources/nodeExecutor/application.properties
View File

@@ -1,4 +1,4 @@
liteflow.rule-source=nodeExecutor/flow.xml liteflow.rule-source=nodeExecutor/flow.xml
liteflow.retry-count=3 liteflow.retry-count=3
liteflow.slot-size=512 liteflow.slot-size=512
liteflow.node-executor=com.yomahub.liteflow.entity.executor.DefaultNodeExecutor liteflow.node-executor-class=com.yomahub.liteflow.entity.executor.DefaultNodeExecutor