diff --git a/cluster/router/chain/chain.go b/cluster/router/chain/chain.go index 6ae9920e0a7f381b505627e71ff06e4ab715e016..8746c1daf7f878a066ea005f910520e07c28318c 100644 --- a/cluster/router/chain/chain.go +++ b/cluster/router/chain/chain.go @@ -65,7 +65,7 @@ func (c *RouterChain) Route(invokers []protocol.Invoker, url *common.URL, invoca return finalInvokers } -// SetInvokers router chain of the initial addresses from registry at the first time. Notify whenever addresses in registry change. +// SetInvokers notify router chain of the initial addresses from registry at the first time. Notify whenever addresses in registry change. func (c *RouterChain) SetInvokers(invokers []protocol.Invoker) { for _, r := range c.routers { if notifyRouter, ok := r.(router.NotifyRouter); ok { diff --git a/cluster/router/tag/tag_router.go b/cluster/router/tag/tag_router.go index c3ee3cbc162a772eed2c812ecb47207c9a1df95a..1a4b74d4861ed0a1ba449853ecac033b35c92429 100644 --- a/cluster/router/tag/tag_router.go +++ b/cluster/router/tag/tag_router.go @@ -146,7 +146,7 @@ func (c *tagRouter) Notify(invokers []protocol.Invoker) { invoker := invokers[0] url := invoker.GetUrl() providerApplication := url.GetParam(constant.RemoteApplicationKey, "") - if providerApplication == "" { + if len(providerApplication) == 0 { logger.Error("TagRouter must getConfig from or subscribe to a specific application, but the application " + "in this TagRouter is not specified.") return