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);