Merge pull request #1056 from kzhan/feature/nacos_consumer_subscribe

fix:nacos service provider does not require subscribe
apache · Feb 23, 2021 · 5db3ebf · 5db3ebf
2 parents 24e0d8c + e6dd108
commit 5db3ebf
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/registry/nacos/registry.go b/registry/nacos/registry.go
@@ -172,6 +172,11 @@ func (nr *nacosRegistry) subscribe(conf *common.URL) (registry.Listener, error)
 
 // subscribe from registry
 func (nr *nacosRegistry) Subscribe(url *common.URL, notifyListener registry.NotifyListener) error {
+	role, _ := strconv.Atoi(nr.URL.GetParam(constant.ROLE_KEY, ""))
+	if role != common.CONSUMER {
+		return nil
+	}
+
 	for {
 		if !nr.IsAvailable() {
 			logger.Warnf("event listener game over.")