diff --git a/common/extension/metadata_service.go b/common/extension/metadata_service.go index cf8b286c66e8f229ab03955de44288cb7f2c7fd6..08ddbc333e85fbfc328bec15aa76d2a588b11afb 100644 --- a/common/extension/metadata_service.go +++ b/common/extension/metadata_service.go @@ -62,6 +62,6 @@ func GetRemoteMetadataService() (service.MetadataService, error) { remoteMetadataService, err = creator() return remoteMetadataService, err } - logger.Info("could not find the metadata service creator for metadataType: remote") + logger.Warn("could not find the metadata service creator for metadataType: remote") return nil, perrors.New(fmt.Sprintf("could not find the metadata service creator for metadataType: remote")) } diff --git a/metadata/service/remote/service.go b/metadata/service/remote/service.go index 1ad246314d06909e70a0c458d622a7df23f3f78f..c72d02e33afdc2752cb8d2d506579d9bac95a851 100644 --- a/metadata/service/remote/service.go +++ b/metadata/service/remote/service.go @@ -124,9 +124,8 @@ func (mts *MetadataService) PublishServiceDefinition(url *common.URL) error { BaseMetadataIdentifier: identifier.BaseMetadataIdentifier{ ServiceInterface: interfaceName, Version: url.GetParam(constant.VERSION_KEY, ""), - // Group: url.GetParam(constant.GROUP_KEY, constant.SERVICE_DISCOVERY_DEFAULT_GROUP), - Group: url.GetParam(constant.GROUP_KEY, constant.DUBBO), - Side: url.GetParam(constant.SIDE_KEY, "provider"), + Group: url.GetParam(constant.GROUP_KEY, constant.DUBBO), + Side: url.GetParam(constant.SIDE_KEY, "provider"), }, } mts.delegateReport.StoreProviderMetadata(id, sd) diff --git a/registry/servicediscovery/service_discovery_registry.go b/registry/servicediscovery/service_discovery_registry.go index 2ca4b8015bc8dbc51a47a46c1bec0301ac961339..c97a7f7b51d2344f1a3fc0c59582e089f1e63b62 100644 --- a/registry/servicediscovery/service_discovery_registry.go +++ b/registry/servicediscovery/service_discovery_registry.go @@ -174,10 +174,6 @@ func (s *serviceDiscoveryRegistry) Register(url *common.URL) error { logger.Warnf("The URL[%s] has been registry!", url.String()) } - err = s.metaDataService.PublishServiceDefinition(url) - if err != nil { - return perrors.WithMessage(err, "publish the service definition failed. ") - } return s.serviceNameMapping.Map(url.GetParam(constant.INTERFACE_KEY, ""), url.GetParam(constant.GROUP_KEY, ""), url.GetParam(constant.Version, ""),