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

enhancement #I633VH 建议FlowBus提供批量移除子链方法

Browse Source
This commit is contained in:
everywhere.z
2022-11-28 23:36:43 +08:00
parent e3c8416606
commit 4592427dde
1 changed files with 7 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -35,8 +35,10 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import java.util.Map;
import java.util.function.Consumer;
import java.util.stream.Collectors;
/**
@@ -67,7 +69,7 @@ public class FlowBus {
//这个方法主要用于第二阶段的替换chain
public static void addChain(Chain chain) {
chainMap.put(chain.getChainName(), chain);
chainMap.put(chain.getChainId(), chain);
}
public static boolean containChain(String chainId) {
@@ -333,4 +335,8 @@ public class FlowBus {
return false;
}
}
public static void removeChain(String... chainIds){
Arrays.stream(chainIds).forEach(FlowBus::removeChain);
}
}