diff --git a/dubbo-cluster/src/main/java/org/apache/dubbo/rpc/cluster/router/condition/config/ListenableStateRouter.java b/dubbo-cluster/src/main/java/org/apache/dubbo/rpc/cluster/router/condition/config/ListenableStateRouter.java index 636a17e13d..01fe2c4a22 100644 --- a/dubbo-cluster/src/main/java/org/apache/dubbo/rpc/cluster/router/condition/config/ListenableStateRouter.java +++ b/dubbo-cluster/src/main/java/org/apache/dubbo/rpc/cluster/router/condition/config/ListenableStateRouter.java @@ -148,7 +148,7 @@ public abstract class ListenableStateRouter extends AbstractStateRouter im } } else { for (AbstractStateRouter router : conditionRouters) { - routeResult = router.route(invokers, url, invocation, needToPrintMessage, nodeHolder); + routeResult = router.route(routeResult, url, invocation, needToPrintMessage, nodeHolder); } } diff --git a/dubbo-cluster/src/main/java/org/apache/dubbo/rpc/cluster/router/condition/config/model/ConditionRuleParser.java b/dubbo-cluster/src/main/java/org/apache/dubbo/rpc/cluster/router/condition/config/model/ConditionRuleParser.java index 23d0678437..37e9da19c6 100644 --- a/dubbo-cluster/src/main/java/org/apache/dubbo/rpc/cluster/router/condition/config/model/ConditionRuleParser.java +++ b/dubbo-cluster/src/main/java/org/apache/dubbo/rpc/cluster/router/condition/config/model/ConditionRuleParser.java @@ -66,7 +66,8 @@ public class ConditionRuleParser { "Invalid condition config version number.", "", "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); } else { // for under v3.1