diff --git a/liteflow-core/src/main/java/com/yomahub/liteflow/core/ComponentInitializer.java b/liteflow-core/src/main/java/com/yomahub/liteflow/core/ComponentInitializer.java index 61bf572d2..7d18ea7cb 100644 --- a/liteflow-core/src/main/java/com/yomahub/liteflow/core/ComponentInitializer.java +++ b/liteflow-core/src/main/java/com/yomahub/liteflow/core/ComponentInitializer.java @@ -47,14 +47,14 @@ public class ComponentInitializer { //先从组件上取@RetryCount标注,如果没有,则看全局配置,全局配置如果不配置的话,默认是0 //默认retryForExceptions为Exception.class LiteflowRetry liteflowRetryAnnotation = AnnotationUtils.getAnnotation(nodeComponent.getClass(), LiteflowRetry.class); + LiteflowConfig liteflowConfig = LiteflowConfigGetter.get(); if (ObjectUtil.isNotNull(liteflowRetryAnnotation)) { nodeComponent.setRetryCount(liteflowRetryAnnotation.retry()); nodeComponent.setRetryForExceptions(liteflowRetryAnnotation.forExceptions()); } else { - LiteflowConfig liteflowConfig = LiteflowConfigGetter.get(); nodeComponent.setRetryCount(liteflowConfig.getRetryCount()); - nodeComponent.setNodeExecutorClass(liteflowConfig.getNodeExecutorClass()); } + nodeComponent.setNodeExecutorClass(liteflowConfig.getNodeExecutorClass()); return nodeComponent; } diff --git a/liteflow-testcase-springboot/src/test/resources/nodeExecutor/application.properties b/liteflow-testcase-springboot/src/test/resources/nodeExecutor/application.properties index 07f53dddf..62a0d3a9b 100644 --- a/liteflow-testcase-springboot/src/test/resources/nodeExecutor/application.properties +++ b/liteflow-testcase-springboot/src/test/resources/nodeExecutor/application.properties @@ -1,4 +1,4 @@ liteflow.rule-source=nodeExecutor/flow.xml liteflow.retry-count=3 liteflow.slot-size=512 -liteflow.node-executor=com.yomahub.liteflow.entity.executor.DefaultNodeExecutor \ No newline at end of file +liteflow.node-executor-class=com.yomahub.liteflow.entity.executor.DefaultNodeExecutor \ No newline at end of file