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

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


The following commit(s) were added to refs/heads/main by this push:
     new 5e774eca0 modify (#2738)
5e774eca0 is described below

commit 5e774eca0f141ead2e5feabe706eedc62be488ec
Author: 王聪洋 <[email protected]>
AuthorDate: Tue Oct 29 17:31:29 2024 +0800

    modify (#2738)
---
 cluster/router/affinity/router.go | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git a/cluster/router/affinity/router.go 
b/cluster/router/affinity/router.go
index 1ced13dcd..49555c7aa 100644
--- a/cluster/router/affinity/router.go
+++ b/cluster/router/affinity/router.go
@@ -61,7 +61,7 @@ func (s *ServiceAffinityRoute) Notify(invokers 
[]protocol.Invoker) {
 
        dynamicConfiguration := conf.GetEnvInstance().GetDynamicConfiguration()
        if dynamicConfiguration == nil {
-               logger.Infof("Config center does not start, Condition router 
will not be enabled")
+               logger.Infof("Config center does not start, Affinity router 
will not be enabled")
                return
        }
 
@@ -101,19 +101,19 @@ func (s *ApplicationAffinityRoute) Notify(invokers 
[]protocol.Invoker) {
        }
        url := invokers[0].GetURL()
        if url == nil {
-               logger.Error("Failed to notify a dynamically condition rule, 
because url is empty")
+               logger.Error("Failed to notify a dynamically affinity rule, 
because url is empty")
                return
        }
 
        dynamicConfiguration := conf.GetEnvInstance().GetDynamicConfiguration()
        if dynamicConfiguration == nil {
-               logger.Infof("Config center does not start, Condition router 
will not be enabled")
+               logger.Infof("Config center does not start, Affinity router 
will not be enabled")
                return
        }
 
        providerApplication := url.GetParam("application", "")
        if providerApplication == "" || providerApplication == 
s.currentApplication {
-               logger.Warn("condition router get providerApplication is empty, 
will not subscribe to provider app rules.")
+               logger.Warn("Affinity router get providerApplication is empty, 
will not subscribe to provider app rules.")
                return
        }
 
@@ -127,7 +127,7 @@ func (s *ApplicationAffinityRoute) Notify(invokers 
[]protocol.Invoker) {
                dynamicConfiguration.AddListener(key, s)
                value, err := dynamicConfiguration.GetRule(key)
                if err != nil {
-                       logger.Errorf("Failed to query condition rule, key=%s, 
err=%v", key, err)
+                       logger.Errorf("Failed to query affinity rule, key=%s, 
err=%v", key, err)
                        return
                }
 

Reply via email to