DUBBO-53 Remoting Client连接出错时,会重试时打出异常栈的日志应该给出*会重试*的说明
git-svn-id: http://code.alibabatech.com/svn/dubbo/trunk@243 1a56cb94-b969-4eaa-88fa-be21384802f2
This commit is contained in:
parent
6fb0b29729
commit
d7ca293ecb
|
|
@ -250,7 +250,7 @@ public class RegistryDirectory<T> extends AbstractDirectory<T> implements Notify
|
|||
}
|
||||
url = ClusterUtils.mergeUrl(url, queryMap); // 合并消费端参数
|
||||
this.directoryUrl = this.directoryUrl.addParametersIfAbsent(url.getParameters()); // 合并提供者参数
|
||||
url = url.addParameter(Constants.CHECK_KEY, String.valueOf(false));// 不检查连接是否成功,总是创建Invoker
|
||||
url = url.addParameter(Constants.CHECK_KEY, String.valueOf(false)); // 不检查连接是否成功,总是创建Invoker!
|
||||
invoker = protocol.refer(serviceType, url);
|
||||
} catch (Throwable t) {
|
||||
logger.error("Failed to refer invoker for interface:"+serviceType+",url:("+url+")" + t.getMessage(), t);
|
||||
|
|
|
|||
|
|
@ -96,7 +96,7 @@ public abstract class AbstractClient extends AbstractEndpoint implements Client
|
|||
throw t;
|
||||
} else {
|
||||
logger.error("Failed to start " + getClass().getSimpleName() + " " + NetUtils.getLocalAddress()
|
||||
+ " connect to the server " + getRemoteAddress() + ", cause: " + t.getMessage(), t);
|
||||
+ " connect to the server " + getRemoteAddress() + " (check == false, ignore and retry later!), cause: " + t.getMessage(), t);
|
||||
}
|
||||
} catch (Throwable t){
|
||||
close();
|
||||
|
|
|
|||
Loading…
Reference in New Issue