fix bug

apache · Dec 1, 2019 · ec0209d · ec0209d
1 parent d978b86
commit ec0209d
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/registry/zookeeper/registry.go b/registry/zookeeper/registry.go
@@ -435,6 +435,7 @@ func (r *zkRegistry) Subscribe(url *common.URL, notifyListener registry.NotifyLi
 
 		for {
 			if serviceEvent, err := listener.Next(); err != nil {
+				logger.Warnf("Selector.watch() = error{%v}", perrors.WithStack(err))
 				listener.Close()
 				break
 			} else {
@@ -454,8 +455,8 @@ func (r *zkRegistry) getListener(conf *common.URL) (*RegistryConfigurationListen
 
 	r.listenerLock.Lock()
 	if r.configListener.isClosed {
-		return nil, perrors.New("configListener already been closed")
 		r.listenerLock.Unlock()
+		return nil, perrors.New("configListener already been closed")
 	}
 	zkListener = r.configListener
 	r.listenerLock.Unlock()