public/liteFlow
1
0
Fork 0
mirror of https://gitee.com/dromara/liteFlow.git synced 2026-05-14 12:12:08 +08:00
Code Issues Packages Projects Releases Wiki Activity

优化

Browse Source
This commit is contained in:
zendwang
2021-03-24 10:29:27 +08:00
parent 2af36b6a74
commit 299effdc67
2 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
liteflow-core/src/main/java/com/yomahub/liteflow/core/FlowExecutor.java
View File

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

2
liteflow-core/src/main/java/com/yomahub/liteflow/flow/FlowBus.java
View File

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