diff --git a/registry/zookeeper/listener.go b/registry/zookeeper/listener.go index 7e4771766139354ebf5b621c3056b0811e2ebd8e..852d6c2688d75579dd84c570ea509916806729d4 100644 --- a/registry/zookeeper/listener.go +++ b/registry/zookeeper/listener.go @@ -23,7 +23,7 @@ import ( ) import ( - gxzookeeper "github.com/dubbogo/gost/database/kv/zk" + zk "github.com/dubbogo/gost/database/kv/zk" perrors "github.com/pkg/errors" ) @@ -113,7 +113,7 @@ func (l *RegistryDataListener) Close() { // RegistryConfigurationListener represent the processor of zookeeper watcher type RegistryConfigurationListener struct { - client *gxzookeeper.ZookeeperClient + client *zk.ZookeeperClient registry *zkRegistry events chan *config_center.ConfigChangeEvent isClosed bool @@ -123,7 +123,7 @@ type RegistryConfigurationListener struct { } // NewRegistryConfigurationListener for listening the event of zk. -func NewRegistryConfigurationListener(client *gxzookeeper.ZookeeperClient, reg *zkRegistry, conf *common.URL) *RegistryConfigurationListener { +func NewRegistryConfigurationListener(client *zk.ZookeeperClient, reg *zkRegistry, conf *common.URL) *RegistryConfigurationListener { reg.WaitGroup().Add(1) return &RegistryConfigurationListener{ client: client,