diff --git a/cluster/cluster_impl/base_cluster_invoker.go b/cluster/cluster_impl/base_cluster_invoker.go index c833ec75d932587684353a86bdca5539148482c8..c46460fc427e60c70eb216a30b282adc9fd2205b 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