[Fix bug](#908) (#910)

apache · Jun 28, 2022 · 02d36df · 02d36df
1 parent 2353c81
commit 02d36df
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/dubbo-admin-server/src/main/java/org/apache/dubbo/admin/service/RegistryServerSync.java b/dubbo-admin-server/src/main/java/org/apache/dubbo/admin/service/RegistryServerSync.java
@@ -98,7 +98,12 @@ public void notify(List<URL> urls) {
         for (URL url : urls) {
             String category = url.getUrlParam().getParameter(Constants.CATEGORY_KEY);
             if (category == null) {
-                category = Constants.PROVIDERS_CATEGORY;
+                // Assign an initial value to category according to the information in url
+                if (Constants.CONSUMER_SIDE.equals(url.getSide()) || Constants.CONSUMER_PROTOCOL.equals(url.getProtocol())) {
+                    category = Constants.CONSUMERS_CATEGORY;
+                } else {
+                    category = Constants.PROVIDERS_CATEGORY;
+                }
             }
             // NOTE: group and version in empty protocol is *
             if (Constants.EMPTY_PROTOCOL.equalsIgnoreCase(url.getProtocol())) {