You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dubbo.apache.org by al...@apache.org on 2021/08/30 03:16:52 UTC
[dubbo] 01/02: Compact old style registerConsumer
This is an automated email from the ASF dual-hosted git repository.
albumenj pushed a commit to branch 3.0-multi-instances
in repository https://gitbox.apache.org/repos/asf/dubbo.git
commit 5af136c3e116cbcfa99927928808e695c444f7aa
Author: Albumen Kevin <jh...@gmail.com>
AuthorDate: Mon Aug 30 11:14:07 2021 +0800
Compact old style registerConsumer
---
.../java/org/apache/dubbo/rpc/model/ServiceRepository.java | 11 ++++++++++-
1 file changed, 10 insertions(+), 1 deletion(-)
diff --git a/dubbo-common/src/main/java/org/apache/dubbo/rpc/model/ServiceRepository.java b/dubbo-common/src/main/java/org/apache/dubbo/rpc/model/ServiceRepository.java
index a004d5a..e73caea 100644
--- a/dubbo-common/src/main/java/org/apache/dubbo/rpc/model/ServiceRepository.java
+++ b/dubbo-common/src/main/java/org/apache/dubbo/rpc/model/ServiceRepository.java
@@ -30,8 +30,8 @@ import org.apache.dubbo.config.ServiceConfigBase;
import java.util.ArrayList;
import java.util.Collections;
import java.util.List;
-import java.util.Set;
import java.util.Map;
+import java.util.Set;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ConcurrentMap;
@@ -110,6 +110,15 @@ public class ServiceRepository extends LifecycleAdapter implements FrameworkExt,
ServiceDescriptor serviceDescriptor,
ReferenceConfigBase<?> rc,
Object proxy,
+ ServiceMetadata serviceMetadata) {
+ ConsumerModel consumerModel = new ConsumerModel(serviceMetadata.getServiceKey(), proxy, serviceDescriptor, rc,
+ serviceMetadata, null);
+ consumers.putIfAbsent(serviceKey, consumerModel);
+ }
+ public void registerConsumer(String serviceKey,
+ ServiceDescriptor serviceDescriptor,
+ ReferenceConfigBase<?> rc,
+ Object proxy,
ServiceMetadata serviceMetadata,
Map<String, AsyncMethodInfo> methodConfigs) {
ConsumerModel consumerModel = new ConsumerModel(serviceMetadata.getServiceKey(), proxy, serviceDescriptor, rc,