diff --git a/registry/nacos/listener.go b/registry/nacos/listener.go index 67c35d1abd08b32210fb124e502c247b224a4f0a..cf6a73d38fbefc1ecb6a80e4911bb0d8fb13a6f6 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 {