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);
         }

Reply via email to