You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@shenyu.apache.org by xi...@apache.org on 2021/08/25 06:13:04 UTC
[incubator-shenyu] branch master updated: refactor
shenyu-register-center: rename zookeeper properties name. (#1973)
This is an automated email from the ASF dual-hosted git repository.
xiaoyu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-shenyu.git
The following commit(s) were added to refs/heads/master by this push:
new 3b656c4 refactor shenyu-register-center: rename zookeeper properties name. (#1973)
3b656c4 is described below
commit 3b656c423940578a540683a718769532e45bbda5
Author: midnight2104 <33...@qq.com>
AuthorDate: Wed Aug 25 14:13:00 2021 +0800
refactor shenyu-register-center: rename zookeeper properties name. (#1973)
---
.../client/zookeeper/ZookeeperClientRegisterRepository.java | 6 +++---
.../server/zookeeper/ZookeeperServerRegisterRepository.java | 6 +++---
2 files changed, 6 insertions(+), 6 deletions(-)
diff --git a/shenyu-register-center/shenyu-register-client/shenyu-register-client-zookeeper/src/main/java/org/apache/shenyu/register/client/zookeeper/ZookeeperClientRegisterRepository.java b/shenyu-register-center/shenyu-register-client/shenyu-register-client-zookeeper/src/main/java/org/apache/shenyu/register/client/zookeeper/ZookeeperClientRegisterRepository.java
index 02f0481..9955d3f 100644
--- a/shenyu-register-center/shenyu-register-client/shenyu-register-client-zookeeper/src/main/java/org/apache/shenyu/register/client/zookeeper/ZookeeperClientRegisterRepository.java
+++ b/shenyu-register-center/shenyu-register-client/shenyu-register-client-zookeeper/src/main/java/org/apache/shenyu/register/client/zookeeper/ZookeeperClientRegisterRepository.java
@@ -50,9 +50,9 @@ public class ZookeeperClientRegisterRepository implements ShenyuClientRegisterRe
@Override
public void init(final ShenyuRegisterCenterConfig config) {
Properties props = config.getProps();
- int zookeeperSessionTimeout = Integer.parseInt(props.getProperty("zookeeperSessionTimeout", "3000"));
- int zookeeperConnectionTimeout = Integer.parseInt(props.getProperty("zookeeperConnectionTimeout", "3000"));
- this.zkClient = new ZkClient(config.getServerLists(), zookeeperSessionTimeout, zookeeperConnectionTimeout);
+ int sessionTimeout = Integer.parseInt(props.getProperty("sessionTimeout", "3000"));
+ int connectionTimeout = Integer.parseInt(props.getProperty("connectionTimeout", "3000"));
+ this.zkClient = new ZkClient(config.getServerLists(), sessionTimeout, connectionTimeout);
this.zkClient.subscribeStateChanges(new ZkStateListener());
}
diff --git a/shenyu-register-center/shenyu-register-server/shenyu-register-server-zookeeper/src/main/java/org/apache/shenyu/register/server/zookeeper/ZookeeperServerRegisterRepository.java b/shenyu-register-center/shenyu-register-server/shenyu-register-server-zookeeper/src/main/java/org/apache/shenyu/register/server/zookeeper/ZookeeperServerRegisterRepository.java
index 37fa481..1df20d5 100644
--- a/shenyu-register-center/shenyu-register-server/shenyu-register-server-zookeeper/src/main/java/org/apache/shenyu/register/server/zookeeper/ZookeeperServerRegisterRepository.java
+++ b/shenyu-register-center/shenyu-register-server/shenyu-register-server-zookeeper/src/main/java/org/apache/shenyu/register/server/zookeeper/ZookeeperServerRegisterRepository.java
@@ -52,9 +52,9 @@ public class ZookeeperServerRegisterRepository implements ShenyuServerRegisterRe
this.init(config);
this.publisher = publisher;
Properties props = config.getProps();
- int zookeeperSessionTimeout = Integer.parseInt(props.getProperty("zookeeperSessionTimeout", "30000"));
- int zookeeperConnectionTimeout = Integer.parseInt(props.getProperty("zookeeperConnectionTimeout", "3000"));
- this.zkClient = new ZkClient(config.getServerLists(), zookeeperSessionTimeout, zookeeperConnectionTimeout);
+ int sessionTimeout = Integer.parseInt(props.getProperty("sessionTimeout", "30000"));
+ int connectionTimeout = Integer.parseInt(props.getProperty("connectionTimeout", "3000"));
+ this.zkClient = new ZkClient(config.getServerLists(), sessionTimeout, connectionTimeout);
initSubscribe();
}