You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dubbo.apache.org by cr...@apache.org on 2022/02/18 09:00:31 UTC
[dubbo] branch 3.0 updated: Print real interface name (#9631)
This is an automated email from the ASF dual-hosted git repository.
crazyhzm pushed a commit to branch 3.0
in repository https://gitbox.apache.org/repos/asf/dubbo.git
The following commit(s) were added to refs/heads/3.0 by this push:
new b1e3b18 Print real interface name (#9631)
b1e3b18 is described below
commit b1e3b18e6998c832689e1f180ed79c1c0a206528
Author: huazhongming <cr...@gmail.com>
AuthorDate: Fri Feb 18 17:00:11 2022 +0800
Print real interface name (#9631)
* print real interface name
* change to parseBoolean
---
.../src/main/java/org/apache/dubbo/config/ReferenceConfig.java | 9 ++++++---
1 file changed, 6 insertions(+), 3 deletions(-)
diff --git a/dubbo-config/dubbo-config-api/src/main/java/org/apache/dubbo/config/ReferenceConfig.java b/dubbo-config/dubbo-config-api/src/main/java/org/apache/dubbo/config/ReferenceConfig.java
index aa2579f..055cb24 100644
--- a/dubbo-config/dubbo-config-api/src/main/java/org/apache/dubbo/config/ReferenceConfig.java
+++ b/dubbo-config/dubbo-config-api/src/main/java/org/apache/dubbo/config/ReferenceConfig.java
@@ -80,6 +80,7 @@ import static org.apache.dubbo.common.utils.StringUtils.splitToSet;
import static org.apache.dubbo.config.Constants.DUBBO_IP_TO_REGISTRY;
import static org.apache.dubbo.registry.Constants.CONSUMER_PROTOCOL;
import static org.apache.dubbo.registry.Constants.REGISTER_IP_KEY;
+import static org.apache.dubbo.rpc.Constants.GENERIC_KEY;
import static org.apache.dubbo.rpc.Constants.LOCAL_PROTOCOL;
import static org.apache.dubbo.rpc.cluster.Constants.PEER_KEY;
import static org.apache.dubbo.rpc.cluster.Constants.REFER_KEY;
@@ -396,7 +397,9 @@ public class ReferenceConfig<T> extends ReferenceConfigBase<T> {
}
if (logger.isInfoEnabled()) {
- logger.info("Referred dubbo service " + interfaceClass.getName());
+ logger.info("Referred dubbo service: [" + referenceParameters.get(INTERFACE_KEY) + "]." +
+ (Boolean.parseBoolean(referenceParameters.get(GENERIC_KEY)) ?
+ " it's GenericService reference" : " it's not GenericService reference"));
}
URL consumerUrl = new ServiceConfigURL(CONSUMER_PROTOCOL, referenceParameters.get(REGISTER_IP_KEY), 0,
@@ -488,7 +491,7 @@ public class ReferenceConfig<T> extends ReferenceConfigBase<T> {
if (urls.size() == 1) {
URL curUrl = urls.get(0);
invoker = protocolSPI.refer(interfaceClass, curUrl);
- if (!UrlUtils.isRegistry(curUrl)){
+ if (!UrlUtils.isRegistry(curUrl)) {
List<Invoker<?>> invokers = new ArrayList<>();
invokers.add(invoker);
invoker = Cluster.getCluster(scopeModel, Cluster.DEFAULT).join(new StaticDirectory(curUrl, invokers), true);
@@ -570,7 +573,7 @@ public class ReferenceConfig<T> extends ReferenceConfigBase<T> {
interfaceClass = Class.forName(interfaceName, true, getInterfaceClassLoader());
} else if (interfaceClass == null) {
interfaceClass = Class.forName(interfaceName, true, Thread.currentThread()
- .getContextClassLoader());
+ .getContextClassLoader());
}
} catch (ClassNotFoundException e) {
throw new IllegalStateException(e.getMessage(), e);