This commit is contained in:
zendwang
2021-03-24 10:32:54 +08:00
parent 299effdc67
commit fc418269a7
2 changed files with 2 additions and 2 deletions

View File

@@ -147,7 +147,7 @@ public class FlowExecutor {
}
try {
//执行chain
// 执行chain
chain.execute(slotIndex);
} catch (Exception e) {
LOG.error("[{}]:chain[{}] execute error on slot[{}]", slot.getRequestId(), chain.getChainName(), slotIndex);

View File

@@ -24,7 +24,7 @@ public class FlowBus {
private FlowBus() {
}
public static Chain getChain(String id) throws Exception{
public static Chain getChain(String id) throws Exception {
if (MapUtils.isEmpty(chainMap)) {
throw new Exception("please config the rule first");
}