From 0a5860761a8e64e5163be03f2bf2fe3c24770e43 Mon Sep 17 00:00:00 2001 From: weifengwu Date: Fri, 2 Feb 2024 14:55:42 +0800 Subject: [PATCH] =?UTF-8?q?filter=E4=BF=AE=E6=94=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../jd/platform/jlog/etcd/EtcdListener.java | 2 +- .../jlog/clientdemo/custom/CustomRespMap.java | 22 ------------------- 2 files changed, 1 insertion(+), 23 deletions(-) delete mode 100644 example/src/main/java/com/jd/platform/jlog/clientdemo/custom/CustomRespMap.java diff --git a/config/config-etcd/src/main/java/com/jd/platform/jlog/etcd/EtcdListener.java b/config/config-etcd/src/main/java/com/jd/platform/jlog/etcd/EtcdListener.java index 2fe5eac..55c00f0 100644 --- a/config/config-etcd/src/main/java/com/jd/platform/jlog/etcd/EtcdListener.java +++ b/config/config-etcd/src/main/java/com/jd/platform/jlog/etcd/EtcdListener.java @@ -34,7 +34,7 @@ public class EtcdListener implements ConfigChangeListener { public EtcdListener() { - iterator = EtcdConfigurator.client.getKvClient().watch(ByteString.copyFromUtf8(ROOT)).asPrefix().start(); + iterator = EtcdConfigurator.client.getKvClient().watch(ByteString.copyFromUtf8("/etcd/workers")).asPrefix().start(); getExecutorService().submit(() -> { while (iterator.hasNext()){ try { diff --git a/example/src/main/java/com/jd/platform/jlog/clientdemo/custom/CustomRespMap.java b/example/src/main/java/com/jd/platform/jlog/clientdemo/custom/CustomRespMap.java deleted file mode 100644 index f3aa600..0000000 --- a/example/src/main/java/com/jd/platform/jlog/clientdemo/custom/CustomRespMap.java +++ /dev/null @@ -1,22 +0,0 @@ -package com.jd.platform.jlog.clientdemo.custom; - -import com.jd.platform.jlog.client.cache.RespMap; -import com.jd.platform.jlog.common.utils.FastJsonUtils; - -import java.util.Map; - -/** - * @author tangbohu - * @version 1.0.0 - * @ClassName CustomRespMap.java - * @Description TODO - * @createTime 2022年03月21日 20:39:00 - */ -public class CustomRespMap implements RespMap { - - @Override - public Map appendRespMap(String cnt) { - - return FastJsonUtils.toMap(cnt); - } -}