fix:nacos service provider does not require subscribe

apache · Feb 16, 2021 · e6dd108 · e6dd108
1 parent 5c76040
commit e6dd108
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.")