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 354ef3f89 [type:refactor] make sure zk client delete success (#3516)
354ef3f89 is described below
commit 354ef3f897eb01f2998e03c7540e5f578f71713d
Author: dragon-zhang <[email protected]>
AuthorDate: Fri Jun 10 17:07:57 2022 +0800
[type:refactor] make sure zk client delete success (#3516)
---
.../apache/shenyu/register/client/server/zookeeper/ZookeeperClient.java | 2 +-
.../org/apache/shenyu/register/client/zookeeper/ZookeeperClient.java | 2 +-
.../org/apache/shenyu/register/instance/zookeeper/ZookeeperClient.java | 2 +-
.../java/org/apache/shenyu/sync/data/zookeeper/ZookeeperClient.java | 2 +-
4 files changed, 4 insertions(+), 4 deletions(-)
diff --git
a/shenyu-register-center/shenyu-register-client-server/shenyu-register-client-server-zookeeper/src/main/java/org/apache/shenyu/register/client/server/zookeeper/ZookeeperClient.java
b/shenyu-register-center/shenyu-register-client-server/shenyu-register-client-server-zookeeper/src/main/java/org/apache/shenyu/register/client/server/zookeeper/ZookeeperClient.java
index b7bf42ab7..f3015930f 100644
---
a/shenyu-register-center/shenyu-register-client-server/shenyu-register-client-server-zookeeper/src/main/java/org/apache/shenyu/register/client/server/zookeeper/ZookeeperClient.java
+++
b/shenyu-register-center/shenyu-register-client-server/shenyu-register-client-server-zookeeper/src/main/java/org/apache/shenyu/register/client/server/zookeeper/ZookeeperClient.java
@@ -183,7 +183,7 @@ public class ZookeeperClient {
*/
public void delete(final String key) {
try {
- client.delete().deletingChildrenIfNeeded().forPath(key);
+
client.delete().guaranteed().deletingChildrenIfNeeded().forPath(key);
} catch (Exception e) {
throw new ShenyuException(e);
}
diff --git
a/shenyu-register-center/shenyu-register-client/shenyu-register-client-zookeeper/src/main/java/org/apache/shenyu/register/client/zookeeper/ZookeeperClient.java
b/shenyu-register-center/shenyu-register-client/shenyu-register-client-zookeeper/src/main/java/org/apache/shenyu/register/client/zookeeper/ZookeeperClient.java
index 27dc1c875..4a9c874bc 100644
---
a/shenyu-register-center/shenyu-register-client/shenyu-register-client-zookeeper/src/main/java/org/apache/shenyu/register/client/zookeeper/ZookeeperClient.java
+++
b/shenyu-register-center/shenyu-register-client/shenyu-register-client-zookeeper/src/main/java/org/apache/shenyu/register/client/zookeeper/ZookeeperClient.java
@@ -183,7 +183,7 @@ public class ZookeeperClient {
*/
public void delete(final String key) {
try {
- client.delete().deletingChildrenIfNeeded().forPath(key);
+
client.delete().guaranteed().deletingChildrenIfNeeded().forPath(key);
} catch (Exception e) {
throw new ShenyuException(e);
}
diff --git
a/shenyu-register-center/shenyu-register-instance/shenyu-register-instance-zookeeper/src/main/java/org/apache/shenyu/register/instance/zookeeper/ZookeeperClient.java
b/shenyu-register-center/shenyu-register-instance/shenyu-register-instance-zookeeper/src/main/java/org/apache/shenyu/register/instance/zookeeper/ZookeeperClient.java
index 1a2d6790f..fbc20d729 100644
---
a/shenyu-register-center/shenyu-register-instance/shenyu-register-instance-zookeeper/src/main/java/org/apache/shenyu/register/instance/zookeeper/ZookeeperClient.java
+++
b/shenyu-register-center/shenyu-register-instance/shenyu-register-instance-zookeeper/src/main/java/org/apache/shenyu/register/instance/zookeeper/ZookeeperClient.java
@@ -183,7 +183,7 @@ public class ZookeeperClient {
*/
public void delete(final String key) {
try {
- client.delete().deletingChildrenIfNeeded().forPath(key);
+
client.delete().guaranteed().deletingChildrenIfNeeded().forPath(key);
} catch (Exception e) {
throw new ShenyuException(e);
}
diff --git
a/shenyu-sync-data-center/shenyu-sync-data-zookeeper/src/main/java/org/apache/shenyu/sync/data/zookeeper/ZookeeperClient.java
b/shenyu-sync-data-center/shenyu-sync-data-zookeeper/src/main/java/org/apache/shenyu/sync/data/zookeeper/ZookeeperClient.java
index b49ab5e1f..ead98ffb6 100644
---
a/shenyu-sync-data-center/shenyu-sync-data-zookeeper/src/main/java/org/apache/shenyu/sync/data/zookeeper/ZookeeperClient.java
+++
b/shenyu-sync-data-center/shenyu-sync-data-zookeeper/src/main/java/org/apache/shenyu/sync/data/zookeeper/ZookeeperClient.java
@@ -185,7 +185,7 @@ public class ZookeeperClient {
*/
public void delete(final String key) {
try {
- client.delete().deletingChildrenIfNeeded().forPath(key);
+
client.delete().guaranteed().deletingChildrenIfNeeded().forPath(key);
} catch (Exception e) {
throw new ShenyuException(e);
}