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

alexstocks pushed a commit to branch 1.1
in repository https://gitbox.apache.org/repos/asf/dubbo-go.git


The following commit(s) were added to refs/heads/1.1 by this push:
     new feaae15  Mod: constant -> version
feaae15 is described below

commit feaae15ed1354555f7af521bd668ffba67dab933
Author: AlexStocks <alexsto...@foxmail.com>
AuthorDate: Wed Aug 14 18:34:45 2019 +0800

    Mod: constant -> version
---
 cluster/cluster_impl/base_cluster_invoker.go     | 4 ++--
 cluster/cluster_impl/failover_cluster_invoker.go | 2 +-
 config/config_loader.go                          | 2 +-
 3 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/cluster/cluster_impl/base_cluster_invoker.go 
b/cluster/cluster_impl/base_cluster_invoker.go
index 5bcadee..52e2156 100644
--- a/cluster/cluster_impl/base_cluster_invoker.go
+++ b/cluster/cluster_impl/base_cluster_invoker.go
@@ -65,7 +65,7 @@ func (invoker *baseClusterInvoker) checkInvokers(invokers 
[]protocol.Invoker, in
        if len(invokers) == 0 {
                ip, _ := utils.GetLocalIP()
                return perrors.Errorf("Failed to invoke the method %v. No 
provider available for the service %v from "+
-                       "registry %v on the consumer %v using the dubbo 
constant %v .Please check if the providers have been started and registered.",
+                       "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().SubURL.Key(), invoker.directory.GetUrl().String(), 
ip, constant.Version)
        }
        return nil
@@ -76,7 +76,7 @@ func (invoker *baseClusterInvoker) checkInvokers(invokers 
[]protocol.Invoker, in
 func (invoker *baseClusterInvoker) checkWhetherDestroyed() error {
        if invoker.destroyed.Load() {
                ip, _ := utils.GetLocalIP()
-               return perrors.Errorf("Rpc cluster invoker for %v on consumer 
%v use dubbo constant %v is now destroyed! can not invoke any more. ",
+               return perrors.Errorf("Rpc cluster invoker for %v on consumer 
%v use dubbo version %v is now destroyed! can not invoke any more. ",
                        invoker.directory.GetUrl().Service(), ip, 
constant.Version)
        }
        return nil
diff --git a/cluster/cluster_impl/failover_cluster_invoker.go 
b/cluster/cluster_impl/failover_cluster_invoker.go
index 2ab5fdc..3dd8c41 100644
--- a/cluster/cluster_impl/failover_cluster_invoker.go
+++ b/cluster/cluster_impl/failover_cluster_invoker.go
@@ -89,7 +89,7 @@ func (invoker *failoverClusterInvoker) Invoke(invocation 
protocol.Invocation) pr
        }
        ip, _ := utils.GetLocalIP()
        return &protocol.RPCResult{Err: perrors.Errorf("Failed to invoke the 
method %v in the service %v. Tried %v times of "+
-               "the providers %v (%v/%v)from the registry %v on the consumer 
%v using the dubbo constant %v. Last error is %v.",
+               "the providers %v (%v/%v)from the registry %v on the consumer 
%v using the dubbo version %v. Last error is %v.",
                methodName, invoker.GetUrl().Service(), retries, providers, 
len(providers), len(invokers), invoker.directory.GetUrl(), ip, 
constant.Version, result.Error().Error(),
        )}
 }
diff --git a/config/config_loader.go b/config/config_loader.go
index cabf3d1..b033ace 100644
--- a/config/config_loader.go
+++ b/config/config_loader.go
@@ -93,7 +93,7 @@ func Load() {
                                                checkok = false
                                                count++
                                                if count > maxWait {
-                                                       
panic(fmt.Sprintf("Failed to check the status of the service %v . No provider 
available for the service to the consumer use dubbo constant %v", 
refconfig.InterfaceName, constant.Version))
+                                                       
panic(fmt.Sprintf("Failed to check the status of the service %v . No provider 
available for the service to the consumer use dubbo version %v", 
refconfig.InterfaceName, constant.Version))
                                                }
                                                time.Sleep(time.Second * 1)
                                                break

Reply via email to