diff --git a/dubbo-registry/dubbo-registry-api/src/main/java/org/apache/dubbo/registry/client/InstanceAddressURL.java b/dubbo-registry/dubbo-registry-api/src/main/java/org/apache/dubbo/registry/client/InstanceAddressURL.java index 3708991dc20a..64714bfce47e 100644 --- a/dubbo-registry/dubbo-registry-api/src/main/java/org/apache/dubbo/registry/client/InstanceAddressURL.java +++ b/dubbo-registry/dubbo-registry-api/src/main/java/org/apache/dubbo/registry/client/InstanceAddressURL.java @@ -495,6 +495,16 @@ public URL addConsumerParams(String protocolServiceKey, Map para */ @Override public String getAnyMethodParameter(String key) { + if (consumerParamFirst(key)) { + URL consumerUrl = RpcContext.getServiceContext().getConsumerUrl(); + if (consumerUrl != null) { + String v = consumerUrl.getAnyMethodParameter(key); + if (StringUtils.isNotEmpty(v)) { + return v; + } + } + } + String suffix = "." + key; String protocolServiceKey = getProtocolServiceKey(); if (StringUtils.isNotEmpty(protocolServiceKey)) {