From 299effdc67676a0ce5f9409ce02b1c1c4caa3d86 Mon Sep 17 00:00:00 2001 From: zendwang Date: Wed, 24 Mar 2021 10:29:27 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../main/java/com/yomahub/liteflow/core/FlowExecutor.java | 8 ++++---- .../src/main/java/com/yomahub/liteflow/flow/FlowBus.java | 2 +- 2 files changed, 5 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 8208db2ae..68f1fa860 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 @@ -149,12 +149,12 @@ public class FlowExecutor { try { //执行chain chain.execute(slotIndex); - }catch(Exception e){ - LOG.error("[{}]:chain[{}] execute error on slot[{}]",slot.getRequestId(),chain.getChainName(),slotIndex); + } catch (Exception e) { + LOG.error("[{}]:chain[{}] execute error on slot[{}]", slot.getRequestId(), chain.getChainName(), slotIndex); slot.setSuccess(false); slot.setErrorMsg(e.getMessage()); - }finally{ - if(!isInnerChain) { + } finally { + if (!isInnerChain) { slot.printStep(); DataBus.releaseSlot(slotIndex); } diff --git a/liteflow-core/src/main/java/com/yomahub/liteflow/flow/FlowBus.java b/liteflow-core/src/main/java/com/yomahub/liteflow/flow/FlowBus.java index acc1d2566..c5a198313 100644 --- a/liteflow-core/src/main/java/com/yomahub/liteflow/flow/FlowBus.java +++ b/liteflow-core/src/main/java/com/yomahub/liteflow/flow/FlowBus.java @@ -25,7 +25,7 @@ public class FlowBus { } public static Chain getChain(String id) throws Exception{ - if(MapUtils.isEmpty(chainMap)){ + if (MapUtils.isEmpty(chainMap)) { throw new Exception("please config the rule first"); } return chainMap.get(id);