From 4034f148439a1991f7c05fb0d57df6c653c53cf4 Mon Sep 17 00:00:00 2001 From: zendwang Date: Fri, 11 Nov 2022 20:33:20 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96etcd=E7=9B=91=E5=90=AC?= =?UTF-8?q?=E8=8A=82=E7=82=B9=E5=8F=98=E5=8C=96=E5=AE=9E=E7=8E=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../liteflow/parser/etcd/EtcdXmlELParser.java | 12 +----------- .../liteflow/parser/etcd/util/EtcdParserHelper.java | 2 +- 2 files changed, 2 insertions(+), 12 deletions(-) diff --git a/liteflow-rule-plugin/liteflow-rule-etcd/src/main/java/com/yomahub/liteflow/parser/etcd/EtcdXmlELParser.java b/liteflow-rule-plugin/liteflow-rule-etcd/src/main/java/com/yomahub/liteflow/parser/etcd/EtcdXmlELParser.java index 0d74805dc..59fc68fbc 100644 --- a/liteflow-rule-plugin/liteflow-rule-etcd/src/main/java/com/yomahub/liteflow/parser/etcd/EtcdXmlELParser.java +++ b/liteflow-rule-plugin/liteflow-rule-etcd/src/main/java/com/yomahub/liteflow/parser/etcd/EtcdXmlELParser.java @@ -57,17 +57,7 @@ public class EtcdXmlELParser extends ClassXmlFlowELParser { try { String content = etcdParserHelper.getContent(); - - Consumer listenerConsumer = t -> { - try { - parse(t); - } catch (Exception e) { - throw new RuntimeException(e); - } - }; - - etcdParserHelper.listen(listenerConsumer); - + etcdParserHelper.listen(); return content; } catch (Exception e){ throw new EtcdException(e.getMessage()); diff --git a/liteflow-rule-plugin/liteflow-rule-etcd/src/main/java/com/yomahub/liteflow/parser/etcd/util/EtcdParserHelper.java b/liteflow-rule-plugin/liteflow-rule-etcd/src/main/java/com/yomahub/liteflow/parser/etcd/util/EtcdParserHelper.java index 496479ddb..ecc89e757 100644 --- a/liteflow-rule-plugin/liteflow-rule-etcd/src/main/java/com/yomahub/liteflow/parser/etcd/util/EtcdParserHelper.java +++ b/liteflow-rule-plugin/liteflow-rule-etcd/src/main/java/com/yomahub/liteflow/parser/etcd/util/EtcdParserHelper.java @@ -145,7 +145,7 @@ public class EtcdParserHelper { /** * 监听 etcd 节点 */ - public void listen(Consumer parseConsumer) { + public void listen() { this.client.watchChildChange(this.etcdParserVO.getChainPath(), (updatePath, updateValue) -> { LOG.info("starting reload flow config... update path={} value={},", updatePath, updateValue); String chainName = updatePath.replace(this.etcdParserVO.getChainPath() + SEPARATOR, "");