fix heartbeat control logic and property name

pull/1621/head
zihenz 3 months ago
parent f04e0bf5ae
commit 16860d6475

@ -80,6 +80,7 @@ public class PolarisDiscoveryProperties {
/** /**
* Enable heartbeat or not. * Enable heartbeat or not.
*/ */
@Value("${spring.cloud.polaris.discovery.heartbeat.enabled:true}")
private Boolean heartbeatEnabled = true; private Boolean heartbeatEnabled = true;
/** /**

@ -87,8 +87,7 @@ public class PolarisServiceRegistry implements ServiceRegistry<PolarisRegistrati
this.polarisDiscoveryHandler = polarisDiscoveryHandler; this.polarisDiscoveryHandler = polarisDiscoveryHandler;
this.staticMetadataManager = staticMetadataManager; this.staticMetadataManager = staticMetadataManager;
if (polarisDiscoveryProperties.getHeartbeatEnabled() if (polarisDiscoveryProperties.getHeartbeatEnabled()) {
&& StringUtils.isNotBlank(polarisDiscoveryProperties.getHealthCheckUrl())) {
this.heartbeatExecutor = Executors this.heartbeatExecutor = Executors
.newSingleThreadScheduledExecutor(new NamedThreadFactory("polaris-heartbeat")); .newSingleThreadScheduledExecutor(new NamedThreadFactory("polaris-heartbeat"));
} }
@ -139,7 +138,7 @@ public class PolarisServiceRegistry implements ServiceRegistry<PolarisRegistrati
try { try {
ProviderAPI providerClient = polarisSDKContextManager.getProviderAPI(); ProviderAPI providerClient = polarisSDKContextManager.getProviderAPI();
InstanceRegisterResponse instanceRegisterResponse; InstanceRegisterResponse instanceRegisterResponse;
if (StringUtils.isBlank(polarisDiscoveryProperties.getHealthCheckUrl())) { if (!polarisDiscoveryProperties.getHeartbeatEnabled() || StringUtils.isBlank(polarisDiscoveryProperties.getHealthCheckUrl())) {
instanceRegisterResponse = providerClient.registerInstance(instanceRegisterRequest); instanceRegisterResponse = providerClient.registerInstance(instanceRegisterRequest);
} }
else { else {

Loading…
Cancel
Save