fix:fix routing rule sync bug when using TSF Consul. (#574)

polarismesh · Dec 9, 2024 · e6eef58 · e6eef58
1 parent d0e0a59
commit e6eef58
Showing 1 changed file with 11 additions and 1 deletion.
diff --git a/...main/java/com/tencent/polaris/plugins/connector/consul/service/router/RoutingService.java b/...main/java/com/tencent/polaris/plugins/connector/consul/service/router/RoutingService.java
@@ -253,7 +253,17 @@ private List<RoutingProto.Route> parseResponse(final HttpResponse response, Stri
                             metadataSourceBuilders.add(metadataSourceBuilder);
                         }
                     }
-                    for (RoutingProto.Source.Builder sourceBuilder : sourceBuilders) {
+                    if (CollectionUtils.isNotEmpty(sourceBuilders)) {
+                        for (RoutingProto.Source.Builder sourceBuilder : sourceBuilders) {
+                            for (RoutingProto.Source.Builder metadataSourceBuilder : metadataSourceBuilders) {
+                                sourceBuilder.putAllMetadata(metadataSourceBuilder.getMetadataMap());
+                            }
+                            sources.add(sourceBuilder.build());
+                        }
+                    } else {
+                        RoutingProto.Source.Builder sourceBuilder = RoutingProto.Source.newBuilder();
+                        sourceBuilder.setNamespace(StringValue.of("*"));
+                        sourceBuilder.setService(StringValue.of("*"));
                         for (RoutingProto.Source.Builder metadataSourceBuilder : metadataSourceBuilders) {
                             sourceBuilder.putAllMetadata(metadataSourceBuilder.getMetadataMap());
                         }