From bd55d91f00f925c2d5d9bb5b9c7aa4b02c2927cf Mon Sep 17 00:00:00 2001 From: zendwang Date: Tue, 8 Nov 2022 20:17:43 +0800 Subject: [PATCH] =?UTF-8?q?enhancement=20=E6=94=AF=E6=8C=81etcd=E5=88=86?= =?UTF-8?q?=E7=A6=BBchain=E4=BB=A5=E5=8F=8A=E8=84=9A=E6=9C=AC=E7=9A=84?= =?UTF-8?q?=E5=AD=98=E5=82=A8=E7=BB=93=E6=9E=84?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../liteflow/parser/etcd/util/EtcdParserHelper.java | 12 +++++------- 1 file changed, 5 insertions(+), 7 deletions(-) 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 4cb4aaebc..1f8590c91 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 @@ -141,19 +141,17 @@ public class EtcdParserHelper { */ public void listen(Consumer 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()); }); }