From cde51b3649c6a90e42399681306d2eb42d5afcee Mon Sep 17 00:00:00 2001
From: "vito.he" <hxmhlt@163.com>
Date: Mon, 9 Sep 2019 14:14:18 +0800
Subject: [PATCH] Mod:remove registry subscribe listen.next sleep error
---
registry/consul/registry.go | 1 -
registry/etcdv3/registry.go | 1 -
registry/nacos/registry.go | 1 -
registry/zookeeper/registry.go | 1 -
4 files changed, 4 deletions(-)
diff --git a/registry/consul/registry.go b/registry/consul/registry.go
index 0fd555429..1fd3e54e9 100644
--- a/registry/consul/registry.go
+++ b/registry/consul/registry.go
@@ -150,7 +150,6 @@ func (r *consulRegistry) Subscribe(url *common.URL, notifyListener registry.Noti
if serviceEvent, err := listener.Next(); err != nil {
logger.Warnf("Selector.watch() = error{%v}", perrors.WithStack(err))
listener.Close()
- time.Sleep(time.Duration(RegistryConnDelay) * time.Second)
return
} else {
logger.Infof("update begin, service event: %v", serviceEvent.String())
diff --git a/registry/etcdv3/registry.go b/registry/etcdv3/registry.go
index 00231ad80..ca02d1f2e 100644
--- a/registry/etcdv3/registry.go
+++ b/registry/etcdv3/registry.go
@@ -352,7 +352,6 @@ func (r *etcdV3Registry) Subscribe(url *common.URL, notifyListener registry.Noti
if serviceEvent, err := listener.Next(); err != nil {
logger.Warnf("Selector.watch() = error{%v}", perrors.WithStack(err))
listener.Close()
- time.Sleep(time.Duration(RegistryConnDelay) * time.Second)
return
} else {
logger.Infof("update begin, service event: %v", serviceEvent.String())
diff --git a/registry/nacos/registry.go b/registry/nacos/registry.go
index 52980006e..3699fab3c 100644
--- a/registry/nacos/registry.go
+++ b/registry/nacos/registry.go
@@ -192,7 +192,6 @@ func (r *nacosRegistry) Subscribe(url *common.URL, notifyListener registry.Notif
if serviceEvent, err := listener.Next(); err != nil {
logger.Warnf("Selector.watch() = error{%v}", perrors.WithStack(err))
listener.Close()
- time.Sleep(time.Duration(RegistryConnDelay) * time.Second)
return
} else {
logger.Infof("update begin, service event: %v", serviceEvent.String())
diff --git a/registry/zookeeper/registry.go b/registry/zookeeper/registry.go
index ba5884882..6f892b8f4 100644
--- a/registry/zookeeper/registry.go
+++ b/registry/zookeeper/registry.go
@@ -420,7 +420,6 @@ func (r *zkRegistry) Subscribe(url *common.URL, notifyListener registry.NotifyLi
if serviceEvent, err := listener.Next(); err != nil {
logger.Warnf("Selector.watch() = error{%v}", perrors.WithStack(err))
listener.Close()
- time.Sleep(time.Duration(RegistryConnDelay) * time.Second)
return
} else {
logger.Infof("update begin, service event: %v", serviceEvent.String())
--
GitLab