From 3731027aab59b086d7be5eb0d73518629ed95a95 Mon Sep 17 00:00:00 2001 From: bryan31 Date: Fri, 25 Feb 2022 18:20:30 +0800 Subject: [PATCH] =?UTF-8?q?=E6=9B=B4=E6=94=B9flowExecutor=E4=B8=ADinit?= =?UTF-8?q?=E7=9A=84=E9=80=BB=E8=BE=91?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/yomahub/liteflow/core/FlowExecutor.java | 11 ++++++----- .../com/yomahub/liteflow/spring/ComponentScanner.java | 1 + 2 files changed, 7 insertions(+), 5 deletions(-) diff --git a/liteflow-core/src/main/java/com/yomahub/liteflow/core/FlowExecutor.java b/liteflow-core/src/main/java/com/yomahub/liteflow/core/FlowExecutor.java index 49d1433d2..9d2b3516d 100644 --- a/liteflow-core/src/main/java/com/yomahub/liteflow/core/FlowExecutor.java +++ b/liteflow-core/src/main/java/com/yomahub/liteflow/core/FlowExecutor.java @@ -60,17 +60,18 @@ public class FlowExecutor { private LiteflowConfig liteflowConfig; - public FlowExecutor() { + public FlowExecutor(){ } public FlowExecutor(LiteflowConfig liteflowConfig){ this.liteflowConfig = liteflowConfig; + if (liteflowConfig.isParseOnStart()){ + this.init(); + } } public static FlowExecutor loadInstance(LiteflowConfig liteflowConfig){ - FlowExecutor flowExecutor = new FlowExecutor(liteflowConfig); - flowExecutor.init(); - return flowExecutor; + return new FlowExecutor(liteflowConfig); } /** @@ -358,7 +359,7 @@ public class FlowExecutor { T slot = DataBus.getSlot(slotIndex); if (ObjectUtil.isNull(slot)) { - throw new NoAvailableSlotException("the slot is not exist"); + throw new NoAvailableSlotException(StrUtil.format("the slot[{}] is not exist", slotIndex)); } if (StrUtil.isBlank(slot.getRequestId())) { diff --git a/liteflow-spring/src/main/java/com/yomahub/liteflow/spring/ComponentScanner.java b/liteflow-spring/src/main/java/com/yomahub/liteflow/spring/ComponentScanner.java index a9d782354..c932bcd80 100644 --- a/liteflow-spring/src/main/java/com/yomahub/liteflow/spring/ComponentScanner.java +++ b/liteflow-spring/src/main/java/com/yomahub/liteflow/spring/ComponentScanner.java @@ -76,3 +76,4 @@ public class ComponentScanner implements BeanPostProcessor { nodeComponentMap.clear(); } } +