fix consul sync problem (apache#5545)

wyfvsfy · Apr 13, 2024 · f26f953 · f26f953
1 parent e806f61
commit f26f953
Showing 1 changed file with 10 additions and 18 deletions.
diff --git a/...r-api/src/main/java/org/apache/shenyu/admin/listener/AbstractPathDataChangedListener.java b/...r-api/src/main/java/org/apache/shenyu/admin/listener/AbstractPathDataChangedListener.java
@@ -26,12 +26,9 @@
 import org.apache.shenyu.common.dto.MetaData;
 import org.apache.shenyu.common.dto.DiscoverySyncData;
 import org.apache.shenyu.common.enums.DataEventTypeEnum;
-import org.apache.shenyu.common.exception.ShenyuException;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-import java.io.UnsupportedEncodingException;
-import java.net.URLEncoder;
 import java.util.List;
 
 /**
@@ -64,21 +61,16 @@ public void onAppAuthChanged(final List<AppAuthData> changed, final DataEventTyp
     @Override
     public void onMetaDataChanged(final List<MetaData> changed, final DataEventTypeEnum eventType) {
         for (MetaData data : changed) {
-            try {
-                String metaDataPath = DefaultPathConstants.buildMetaDataPath(URLEncoder.encode(data.getPath(), "UTF-8"));
-                // delete
-                if (eventType == DataEventTypeEnum.DELETE) {
-                    deleteNode(metaDataPath);
-                    LOG.debug("[DataChangedListener] delete appKey {}", metaDataPath);
-                    continue;
-                }
-                // create or update
-                createOrUpdate(metaDataPath, data);
-                LOG.debug("[DataChangedListener] change metaDataPath {}", metaDataPath);
-            } catch (UnsupportedEncodingException e) {
-                LOG.error("[DataChangedListener] url encode error.", e);
-                throw new ShenyuException(e.getMessage());
+            String metaDataPath = DefaultPathConstants.buildMetaDataPath(data.getPath());
+            // delete
+            if (eventType == DataEventTypeEnum.DELETE) {
+                deleteNode(metaDataPath);
+                LOG.debug("[DataChangedListener] delete appKey {}", metaDataPath);
+                continue;
             }
+            // create or update
+            createOrUpdate(metaDataPath, data);
+            LOG.debug("[DataChangedListener] change metaDataPath {}", metaDataPath);
         }
     }
 
@@ -196,4 +188,4 @@ public void onRuleChanged(final List<RuleData> changed, final DataEventTypeEnum
      * @param selectorParentPath selectorParentPath
      */
     public abstract void deletePathRecursive(String selectorParentPath);
-}
+}