diff --git a/registry/zookeeper/registry_test.go b/registry/zookeeper/registry_test.go index b7451f9543518b8f366bb026b4c0b06d7df8474b..d4141e8012f8ce1291175bc4b4ed7b1a85e502e2 100644 --- a/registry/zookeeper/registry_test.go +++ b/registry/zookeeper/registry_test.go @@ -61,6 +61,13 @@ func Test_UnRegister(t *testing.T) { children, err = reg.client.GetChildren("/dubbo/com.ikurento.user.UserProvider/providers") assert.Equal(t, 0, len(children)) assert.Error(t, err) + assert.True(t, reg.IsAvailable()) + + err = reg.Register(url) + children, _ = reg.client.GetChildren("/dubbo/com.ikurento.user.UserProvider/providers") + assert.Regexp(t, ".*dubbo%3A%2F%2F127.0.0.1%3A20000%2Fcom.ikurento.user.UserProvider%3Fanyhost%3Dtrue%26cluster%3Dmock%26.*.serviceid%3Dsoa.mock", children) + assert.NoError(t, err) + } func Test_Subscribe(t *testing.T) { diff --git a/remoting/zookeeper/listener.go b/remoting/zookeeper/listener.go index 6c9d072385bd0a2ac87eabd3ad4ae13663ea22e9..097106acf6b44d03708362d587b5faa8281edeab 100644 --- a/remoting/zookeeper/listener.go +++ b/remoting/zookeeper/listener.go @@ -314,7 +314,7 @@ func (l *ZkEventListener) valid() bool { return l.client.ZkConnValid() } -// Close ... +// Close will let client listen exit func (l *ZkEventListener) Close() { close(l.client.exit) l.wg.Wait()