This is an automated email from the ASF dual-hosted git repository.
joezou pushed a commit to branch 1.5.1
in repository https://gitbox.apache.org/repos/asf/dubbo-go.git
The following commit(s) were added to refs/heads/1.5.1 by this push:
new 43a3059 asynchronous subscribe nacos service info
new e21a257 Merge pull request #721 from lzp0412/develop
43a3059 is described below
commit 43a30595f519c0236e060c05d78965910bf191f0
Author: lzp0412 <[email protected]>
AuthorDate: Wed Aug 19 19:31:06 2020 +0800
asynchronous subscribe nacos service info
---
registry/nacos/listener.go | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/registry/nacos/listener.go b/registry/nacos/listener.go
index 67c35d1..cf6a73d 100644
--- a/registry/nacos/listener.go
+++ b/registry/nacos/listener.go
@@ -188,7 +188,8 @@ func (nl *nacosListener) startListen() error {
}
serviceName := getSubscribeName(nl.listenUrl)
nl.subscribeParam = &vo.SubscribeParam{ServiceName: serviceName,
SubscribeCallback: nl.Callback}
- return nl.namingClient.Subscribe(nl.subscribeParam)
+ go nl.namingClient.Subscribe(nl.subscribeParam)
+ return nil
}
func (nl *nacosListener) stopListen() error {
