diff --git a/registry/polaris/registry.go b/registry/polaris/registry.go index d95ea8e59a..1417ba9366 100644 --- a/registry/polaris/registry.go +++ b/registry/polaris/registry.go @@ -46,7 +46,8 @@ var localIP = "" const ( // RegistryConnDelay registry connection delay - RegistryConnDelay = 3 + RegistryConnDelay = 3 + defaultHeartbeatIntervalSec = 5 ) func init() { @@ -291,7 +292,7 @@ func createRegisterParam(url *common.URL, serviceName string) *api.InstanceRegis }) metadata[constant.PolarisDubboPath] = url.Path - return &api.InstanceRegisterRequest{ + req := &api.InstanceRegisterRequest{ InstanceRegisterRequest: model.InstanceRegisterRequest{ Service: serviceName, Namespace: url.GetParam(constant.PolarisNamespace, constant.PolarisDefaultNamespace), @@ -301,6 +302,10 @@ func createRegisterParam(url *common.URL, serviceName string) *api.InstanceRegis Metadata: metadata, }, } + + req.SetTTL(defaultHeartbeatIntervalSec) + + return req } // createDeregisterParam convert dubbo url to polaris instance deregister request diff --git a/registry/polaris/service_discovery.go b/registry/polaris/service_discovery.go index 6ae06c8401..605be176a3 100644 --- a/registry/polaris/service_discovery.go +++ b/registry/polaris/service_discovery.go @@ -94,9 +94,9 @@ func (polaris *polarisServiceDiscovery) Destroy() error { inst.cancel() err := polaris.Unregister(inst.instance) - logger.Infof("Unregister nacos instance:%+v", inst) + logger.Infof("Unregister polaris instance:%+v", inst) if err != nil { - logger.Errorf("Unregister nacos instance:%+v, err:%+v", inst, err) + logger.Errorf("Unregister polaris instance:%+v, err:%+v", inst, err) } } polaris.provider.Destroy()