[incubator-dubbo] branch master updated: reference config initialized. (#4067)

[huxing]

This is an automated email from the ASF dual-hosted git repository.

huxing pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-dubbo.git


The following commit(s) were added to refs/heads/master by this push:
     new 8646277  reference config initialized. (#4067)
8646277 is described below

commit 86462778281953b3b4602dbccb456fab65bd7c32
Author: Haiyang <haiyang_1...@163.com>
AuthorDate: Fri May 17 15:54:34 2019 +0800

    reference config initialized. (#4067)
---
 .../src/main/java/org/apache/dubbo/config/ReferenceConfig.java        | 4 +---
 1 file changed, 1 insertion(+), 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 2d50ae5..8ec800c 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
@@ -273,7 +273,6 @@ public class ReferenceConfig<T> extends 
AbstractReferenceConfig {
         if (initialized) {
             return;
         }
-        initialized = true;
         checkStubAndLocal(interfaceClass);
         checkMock(interfaceClass);
         Map<String, String> map = new HashMap<String, String>();
@@ -331,6 +330,7 @@ public class ReferenceConfig<T> extends 
AbstractReferenceConfig {
 
         String serviceKey = URL.buildKey(interfaceName, group, version);
         ApplicationModel.initConsumerModel(serviceKey, 
buildConsumerModel(serviceKey, attributes));
+        initialized = true;
     }
 
     private ConsumerModel buildConsumerModel(String serviceKey, Map<String, 
Object> attributes) {
@@ -414,8 +414,6 @@ public class ReferenceConfig<T> extends 
AbstractReferenceConfig {
         }
 
         if (shouldCheck() && !invoker.isAvailable()) {
-            // make it possible for consumer to retry later if provider is 
temporarily unavailable
-            initialized = false;
             throw new IllegalStateException("Failed to check the status of the 
service " + interfaceName + ". No provider available for the service " + (group 
== null ? "" : group + "/") + interfaceName + (version == null ? "" : ":" + 
version) + " from the url " + invoker.getUrl() + " to the consumer " + 
NetUtils.getLocalHost() + " use dubbo version " + Version.getVersion());
         }
         if (logger.isInfoEnabled()) {