Skip to content
Snippets Groups Projects
Commit 4fb0a358 authored by AlexStocks's avatar AlexStocks
Browse files

cp from pr #1129

parent d5cf4c5c
No related branches found
No related tags found
No related merge requests found
...@@ -79,6 +79,7 @@ func newZkRegistry(url *common.URL) (registry.Registry, error) { ...@@ -79,6 +79,7 @@ func newZkRegistry(url *common.URL) (registry.Registry, error) {
return nil, err return nil, err
} }
r.WaitGroup().Add(1) //zk client start successful, then wg +1
go zookeeper.HandleClientRestart(r) go zookeeper.HandleClientRestart(r)
r.listener = zookeeper.NewZkEventListener(r.client) r.listener = zookeeper.NewZkEventListener(r.client)
......
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment