fix invoker (#2533)

apache · Dec 8, 2023 · 90e7f69 · 90e7f69
1 parent ffb8b76
commit 90e7f69
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/config/service_config.go b/config/service_config.go
@@ -337,7 +337,7 @@ func (s *ServiceConfig) Export() error {
 					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
@@ -225,7 +225,7 @@ func (svcOpts *ServiceOptions) export(info *ServiceInfo) error {
 
 			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 @@ func (svcOpts *ServiceOptions) export(info *ServiceInfo) error {
 					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))