[Issues] 765 Support customized beat interval of Nacos client

pull/766/head
ly 6 years ago
parent d332ae666b
commit 3860f5eabb

@ -142,7 +142,7 @@ public class NacosDiscoveryProperties {
*/ */
private String secretKey; private String secretKey;
/** /**
* Heart beat interval. Time unit: second. * Heart beat interval. Time unit: second.
*/ */
private Integer heartBeatInterval; private Integer heartBeatInterval;
@ -349,21 +349,21 @@ public class NacosDiscoveryProperties {
this.heartBeatInterval = heartBeatInterval; this.heartBeatInterval = heartBeatInterval;
} }
public Integer getHeartBeatTimeout() { public Integer getHeartBeatTimeout() {
return heartBeatTimeout; return heartBeatTimeout;
} }
public void setHeartBeatTimeout(Integer heartBeatTimeout) { public void setHeartBeatTimeout(Integer heartBeatTimeout) {
this.heartBeatTimeout = heartBeatTimeout; this.heartBeatTimeout = heartBeatTimeout;
} }
public Integer getIpDeleteTimeout() { public Integer getIpDeleteTimeout() {
return ipDeleteTimeout; return ipDeleteTimeout;
} }
public void setIpDeleteTimeout(Integer ipDeleteTimeout) { public void setIpDeleteTimeout(Integer ipDeleteTimeout) {
this.ipDeleteTimeout = ipDeleteTimeout; this.ipDeleteTimeout = ipDeleteTimeout;
} }
public String getNamingLoadCacheAtStart() { public String getNamingLoadCacheAtStart() {
return namingLoadCacheAtStart; return namingLoadCacheAtStart;

@ -80,16 +80,16 @@ public class NacosRegistration implements Registration, ServiceInstance {
if (null != nacosDiscoveryProperties.getHeartBeatInterval()) { if (null != nacosDiscoveryProperties.getHeartBeatInterval()) {
metadata.put(PreservedMetadataKeys.HEART_BEAT_INTERVAL, metadata.put(PreservedMetadataKeys.HEART_BEAT_INTERVAL,
nacosDiscoveryProperties.getHeartBeatInterval().toString()); nacosDiscoveryProperties.getHeartBeatInterval().toString());
} }
if (null != nacosDiscoveryProperties.getHeartBeatTimeout()) { if (null != nacosDiscoveryProperties.getHeartBeatTimeout()) {
metadata.put(PreservedMetadataKeys.HEART_BEAT_TIMEOUT, metadata.put(PreservedMetadataKeys.HEART_BEAT_TIMEOUT,
nacosDiscoveryProperties.getHeartBeatTimeout().toString()); nacosDiscoveryProperties.getHeartBeatTimeout().toString());
} }
if (null != nacosDiscoveryProperties.getIpDeleteTimeout()) { if (null != nacosDiscoveryProperties.getIpDeleteTimeout()) {
metadata.put(PreservedMetadataKeys.IP_DELETE_TIMEOUT, metadata.put(PreservedMetadataKeys.IP_DELETE_TIMEOUT,
nacosDiscoveryProperties.getIpDeleteTimeout().toString()); nacosDiscoveryProperties.getIpDeleteTimeout().toString());
} }
} }
@Override @Override

@ -169,18 +169,18 @@ public class NacosAutoServiceRegistrationTests {
} }
private void checkoutNacosDiscoveryHeartBeatInterval() { private void checkoutNacosDiscoveryHeartBeatInterval() {
assertEquals("NacosDiscoveryProperties heart beat interval was wrong", Integer.valueOf(3), assertEquals("NacosDiscoveryProperties heart beat interval was wrong",
properties.getHeartBeatInterval()); Integer.valueOf(3), properties.getHeartBeatInterval());
} }
private void checkoutNacosDiscoveryHeartBeatTimeout() { private void checkoutNacosDiscoveryHeartBeatTimeout() {
assertEquals("NacosDiscoveryProperties heart beat timeout was wrong", Integer.valueOf(6), assertEquals("NacosDiscoveryProperties heart beat timeout was wrong",
properties.getHeartBeatInterval()); Integer.valueOf(6), properties.getHeartBeatInterval());
} }
private void checkoutNacosDiscoveryIpDeleteTimeout() { private void checkoutNacosDiscoveryIpDeleteTimeout() {
assertEquals("NacosDiscoveryProperties ip delete timeout was wrong", Integer.valueOf(9), assertEquals("NacosDiscoveryProperties ip delete timeout was wrong",
properties.getHeartBeatInterval()); Integer.valueOf(9), properties.getHeartBeatInterval());
} }
private void checkoutNacosDiscoveryServiceName() { private void checkoutNacosDiscoveryServiceName() {

Loading…
Cancel
Save