Skip to content
Snippets Groups Projects
Commit ad8a8ad9 authored by cvictory's avatar cvictory
Browse files

fix metadata report fail

parent b8f21c49
No related branches found
No related tags found
No related merge requests found
......@@ -40,10 +40,13 @@ import (
"github.com/apache/dubbo-go/common/constant"
"github.com/apache/dubbo-go/common/extension"
"github.com/apache/dubbo-go/common/logger"
"github.com/apache/dubbo-go/metadata/service"
"github.com/apache/dubbo-go/protocol"
"github.com/apache/dubbo-go/protocol/protocolwrapper"
)
var remoteMetadataService service.MetadataService
// ServiceConfig is the configuration of the service provider
type ServiceConfig struct {
context context.Context
......@@ -223,6 +226,7 @@ func (c *ServiceConfig) Export() error {
}
c.exporters = append(c.exporters, exporter)
}
PublishServiceDefinition(ivkURL)
}
c.exported.Store(true)
return nil
......@@ -332,3 +336,17 @@ func (c *ServiceConfig) GetExportedUrls() []*common.URL {
}
return nil
}
func PublishServiceDefinition(url *common.URL) {
if remoteMetadataService == nil {
var err error
if remoteMetadataService, err = extension.GetMetadataService("remote"); err != nil {
logger.Warnf("get remote metadataService fail. %v", err)
return
} else if remoteMetadataService == nil {
logger.Info("get remote metadataService will nil.")
return
}
}
remoteMetadataService.PublishServiceDefinition(url)
}
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment