refactor: delete EtcdRefresherHandler redundant comments

pull/1554/head
Song 1 year ago
parent 5ebe215f5f
commit 9c3915413b

@ -17,7 +17,6 @@
package cn.hippo4j.config.springboot.starter.refresher; package cn.hippo4j.config.springboot.starter.refresher;
import cn.hippo4j.common.toolkit.JSONUtil;
import cn.hippo4j.common.toolkit.StringUtil; import cn.hippo4j.common.toolkit.StringUtil;
import cn.hippo4j.threadpool.dynamic.mode.config.properties.BootstrapConfigProperties; import cn.hippo4j.threadpool.dynamic.mode.config.properties.BootstrapConfigProperties;
import io.etcd.jetcd.ByteSequence; import io.etcd.jetcd.ByteSequence;
@ -65,7 +64,6 @@ public class EtcdRefresherHandler extends AbstractConfigThreadPoolDynamicRefresh
String key = etcd.get(KEY); String key = etcd.get(KEY);
Charset charset = StringUtil.isBlank(etcd.get(CHARSET)) ? StandardCharsets.UTF_8 : Charset.forName(etcd.get(CHARSET)); Charset charset = StringUtil.isBlank(etcd.get(CHARSET)) ? StandardCharsets.UTF_8 : Charset.forName(etcd.get(CHARSET));
initClient(etcd, charset); initClient(etcd, charset);
// TODO Currently only supports json
GetResponse getResponse = client.getKVClient().get(ByteSequence.from(key, charset)).get(); GetResponse getResponse = client.getKVClient().get(ByteSequence.from(key, charset)).get();
KeyValue keyValue = getResponse.getKvs().get(0); KeyValue keyValue = getResponse.getKvs().get(0);
if (Objects.isNull(keyValue)) { if (Objects.isNull(keyValue)) {
@ -103,7 +101,6 @@ public class EtcdRefresherHandler extends AbstractConfigThreadPoolDynamicRefresh
* @param charset charset * @param charset charset
*/ */
private void initClient(Map<String, String> etcd, Charset charset) { private void initClient(Map<String, String> etcd, Charset charset) {
// TODO
if (Objects.isNull(client)) { if (Objects.isNull(client)) {
String user = etcd.get(USER); String user = etcd.get(USER);
String password = etcd.get(PASSWORD); String password = etcd.get(PASSWORD);

Loading…
Cancel
Save