From d27a5e0d10c9806152b51e2d2c86acbcc48ebb7a Mon Sep 17 00:00:00 2001
From: "vito.he" <hxmhlt@163.com>
Date: Thu, 16 May 2019 14:09:36 +0800
Subject: [PATCH] Fix: log bug in checkInvokers
---
cluster/cluster_impl/base_cluster_invoker.go | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/cluster/cluster_impl/base_cluster_invoker.go b/cluster/cluster_impl/base_cluster_invoker.go
index c833ec75d..c46460fc4 100644
--- a/cluster/cluster_impl/base_cluster_invoker.go
+++ b/cluster/cluster_impl/base_cluster_invoker.go
@@ -38,7 +38,7 @@ func (invoker *baseClusterInvoker) Destroy() {
}
func (invoker *baseClusterInvoker) IsAvailable() bool {
- //TODO:涓嶇悊瑙ava鐗堟湰涓叧浜巗tikyInvoker鐨勯€昏緫鎵€浠ュ厛涓嶅啓
+ //TODO:sticky connection
return invoker.directory.IsAvailable()
}
@@ -46,9 +46,9 @@ func (invoker *baseClusterInvoker) IsAvailable() bool {
func (invoker *baseClusterInvoker) checkInvokers(invokers []protocol.Invoker, invocation protocol.Invocation) error {
if len(invokers) == 0 {
ip, _ := gxnet.GetLocalIP()
- return jerrors.Errorf("Failed to invoke the method %v . No provider available for the service %v from"+
+ return jerrors.Errorf("Failed to invoke the method %v . No provider available for the service %v from "+
"registry %v on the consumer %v using the dubbo version %v .Please check if the providers have been started and registered.",
- invocation.MethodName(), invoker.directory.GetUrl().Key(), invoker.directory.GetUrl().String(), ip, version.Version)
+ invocation.MethodName(), invoker.directory.GetUrl().SubURL.Key(), invoker.directory.GetUrl().String(), ip, version.Version)
}
return nil
--
GitLab