fix invoker (#2533)
diff --git a/config/service_config.go b/config/service_config.go
index e54e119..0454b6a 100644
--- a/config/service_config.go
+++ b/config/service_config.go
@@ -337,7 +337,7 @@
logger.Warnf("SetMetadataServiceURL error = %s", err)
}
}
- s.generatorInvoker(ivkURL, info)
+ invoker = s.generatorInvoker(ivkURL, info)
exporter := extension.GetProtocol(protocolwrapper.FILTER).Export(invoker)
if exporter == nil {
return perrors.New(fmt.Sprintf("Filter protocol without registry new exporter error, url is {%v}", ivkURL))
diff --git a/server/action.go b/server/action.go
index 31bfaca..cf62658 100644
--- a/server/action.go
+++ b/server/action.go
@@ -225,7 +225,7 @@
for _, regUrl := range regUrls {
setRegistrySubURL(ivkURL, regUrl)
- svcOpts.generatorInvoker(regUrl, info)
+ invoker = svcOpts.generatorInvoker(regUrl, info)
exporter := svcOpts.cacheProtocol.Export(invoker)
if exporter == nil {
return perrors.New(fmt.Sprintf("Registry protocol new exporter error, registry is {%v}, url is {%v}", regUrl, ivkURL))
@@ -243,7 +243,7 @@
logger.Warnf("SetMetadataServiceURL error = %svcOpts", err)
}
}
- svcOpts.generatorInvoker(ivkURL, info)
+ invoker = svcOpts.generatorInvoker(ivkURL, info)
exporter := extension.GetProtocol(protocolwrapper.FILTER).Export(invoker)
if exporter == nil {
return perrors.New(fmt.Sprintf("Filter protocol without registry new exporter error, url is {%v}", ivkURL))
