You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dubbo.apache.org by dm...@apache.org on 2023/12/08 07:39:37 UTC
(dubbo-go) branch main updated: fix invoker (#2533)
This is an automated email from the ASF dual-hosted git repository.
dmwangnima pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/dubbo-go.git
The following commit(s) were added to refs/heads/main by this push:
new 90e7f6998 fix invoker (#2533)
90e7f6998 is described below
commit 90e7f69980f4643d140b20d5a2641b9f8cb3d369
Author: finalt <fi...@163.com>
AuthorDate: Fri Dec 8 15:39:32 2023 +0800
fix invoker (#2533)
---
config/service_config.go | 2 +-
server/action.go | 4 ++--
2 files changed, 3 insertions(+), 3 deletions(-)
diff --git a/config/service_config.go b/config/service_config.go
index e54e1191e..0454b6aca 100644
--- 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
index 31bfaca2a..cf6265821 100644
--- 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))