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

enhancement 支持etcd分离chain以及脚本的存储结构

Browse Source
This commit is contained in:
zendwang
2022-11-08 20:17:43 +08:00
parent 9467f8ba6b
commit bd55d91f00
1 changed files with 5 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
liteflow-rule-plugin/liteflow-rule-etcd/src/main/java/com/yomahub/liteflow/parser/etcd/util/EtcdParserHelper.java
View File

@@ -141,19 +141,17 @@ public class EtcdParserHelper {
*/
public void listen(Consumer<String> parseConsumer) {
this.client.watchChildChange(this.etcdParserVO.getChainPath(), (updatePath, updateValue) -> {
LOG.info("update path={} value={},starting reload flow config...", updatePath, updateValue);
String content = getContent();
LOG.info("update path={} value={},content={}", content);
// parseConsumer.accept(content);
LOG.info("starting reload flow config... update path={} value={},", updatePath, updateValue);
parseConsumer.accept(getContent());
}, (deletePath) -> {
LOG.info("delete path={},starting reload flow config...", deletePath);
LOG.info("starting reload flow config... delete path={}", deletePath);
parseConsumer.accept(getContent());
});
this.client.watchChildChange(this.etcdParserVO.getScriptPath(), (updatePath, updateValue) -> {
LOG.info("update path={} value={},starting reload flow config...", updatePath, updateValue);
LOG.info("starting reload flow config... update path={} value={}", updatePath, updateValue);
parseConsumer.accept(getContent());
}, (deletePath) -> {
LOG.info("delete path={},starting reload flow config....", deletePath);
LOG.info("starting reload flow config... delete path={}", deletePath);
parseConsumer.accept(getContent());
});
}