diff --git a/registry/protocol/protocol.go b/registry/protocol/protocol.go index d1e02b11b21396d7963d2cfffb8e1211b6ee6666..c746cf8ef291bd198274971aad23e91ba6443e36 100644 --- a/registry/protocol/protocol.go +++ b/registry/protocol/protocol.go @@ -174,7 +174,7 @@ func (proto *registryProtocol) Export(invoker protocol.Invoker) protocol.Exporte logger.Infof("The exporter has not been cached, and will return a new exporter!") } - reg.Subscribe(overriderUrl, overrideSubscribeListener) + go reg.Subscribe(overriderUrl, overrideSubscribeListener) return cachedExporter.(protocol.Exporter) }