diff --git a/registry/zookeeper/listener.go b/registry/zookeeper/listener.go index 355e7c18f571d5a61c5233f10c2f9f07c8dc6d53..54edd9cc12c9d92eceeab4a5bc449e83c2f91f73 100644 --- a/registry/zookeeper/listener.go +++ b/registry/zookeeper/listener.go @@ -155,6 +155,7 @@ func (l *RegistryConfigurationListener) Close() { l.registry.WaitGroup().Done() }) } + // valid return the true if the client conn isn't nil func (l *RegistryConfigurationListener) valid() bool { return l.client.ZkConnValid() diff --git a/registry/zookeeper/registry.go b/registry/zookeeper/registry.go index 9d74aa9d6ec477a379eeb64131c53215bbb93214..8682806d0a6c3e6e6d6555f96b18c9560d8b1d36 100644 --- a/registry/zookeeper/registry.go +++ b/registry/zookeeper/registry.go @@ -232,6 +232,5 @@ func (r *zkRegistry) getListener(conf *common.URL) (*RegistryConfigurationListen go r.listener.ListenServiceEvent(fmt.Sprintf("/dubbo/%s/"+constant.DEFAULT_CATEGORY, url.QueryEscape(conf.Service())), r.dataListener) - return zkListener, nil }