From b0c8cc115d4f237afbc4b7d1813dd71c2cccc722 Mon Sep 17 00:00:00 2001 From: "bryan.zhang" Date: Wed, 22 Nov 2017 16:06:11 +0800 Subject: [PATCH] =?UTF-8?q?=E5=8A=A0=E5=85=A5=E8=8A=82=E7=82=B9=E7=9A=84?= =?UTF-8?q?=E9=98=80=E9=97=A8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/main/java/com/thebeastshop/liteflow/core/Component.java | 4 ++++ .../java/com/thebeastshop/liteflow/core/FlowExecutor.java | 5 ++++- 2 files changed, 8 insertions(+), 1 deletion(-) diff --git a/src/main/java/com/thebeastshop/liteflow/core/Component.java b/src/main/java/com/thebeastshop/liteflow/core/Component.java index 34d16aa4e..86c1a3da0 100644 --- a/src/main/java/com/thebeastshop/liteflow/core/Component.java +++ b/src/main/java/com/thebeastshop/liteflow/core/Component.java @@ -51,6 +51,10 @@ public abstract class Component { protected abstract void process() throws Exception; + protected boolean isAccess(){ + return true; + } + public boolean isContinueOnError() { return continueOnError; } diff --git a/src/main/java/com/thebeastshop/liteflow/core/FlowExecutor.java b/src/main/java/com/thebeastshop/liteflow/core/FlowExecutor.java index 739cba7ca..f51b11ac4 100644 --- a/src/main/java/com/thebeastshop/liteflow/core/FlowExecutor.java +++ b/src/main/java/com/thebeastshop/liteflow/core/FlowExecutor.java @@ -73,7 +73,10 @@ public class FlowExecutor { for(Node node : nodeList){ component = node.getInstance(); try{ - component.setSlotIndex(slotIndex).execute(); + component.setSlotIndex(slotIndex); + if(component.isAccess()){ + component.execute(); + } }catch(Throwable t){ if(component.isContinueOnError()){ LOG.error("component[{}] cause error,but flow is still go on",t,component.getClass().getSimpleName());