natas_hw
/
dubbo
0
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

bug fix

This commit is contained in:
王聪洋 2024-06-21 18:36:44 +08:00
parent 2e44de363c
commit 8f995cb993
2 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
dubbo-cluster/src/main/java/org/apache/dubbo/rpc/cluster/router/condition/config/ListenableStateRouter.java
View File

@ -148,7 +148,7 @@ public abstract class ListenableStateRouter<T> extends AbstractStateRouter<T> im
} }
} else { } else {
for (AbstractStateRouter<T> router : conditionRouters) { for (AbstractStateRouter<T> router : conditionRouters) {
routeResult = router.route(invokers, url, invocation, needToPrintMessage, nodeHolder); routeResult = router.route(routeResult, url, invocation, needToPrintMessage, nodeHolder);
} }
} }

3
dubbo-cluster/src/main/java/org/apache/dubbo/rpc/cluster/router/condition/config/model/ConditionRuleParser.java
View File

@ -66,7 +66,8 @@ public class ConditionRuleParser {
"Invalid condition config version number.", "Invalid condition config version number.",
"", "",
"Ignore this configuration. Only " + RULE_VERSION_V31 + " and below are supported in this release"); "Ignore this configuration. Only " + RULE_VERSION_V31 + " and below are supported in this release");
rule = ConditionRouterRule.parseFromMap(map); // rule = ConditionRouterRule.parseFromMap(map);
rule = new ConditionRouterRule();
rule.setValid(false); rule.setValid(false);
} else { } else {
// for under v3.1 // for under v3.1