SpringCloud/spring-cloud-consul
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

cancle the previous ttl task when putting a new task

Browse Source
This commit is contained in:
lowzj
2016-11-01 13:28:30 +08:00
parent ab89d06586
commit 0605ce71a6
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
spring-cloud-consul-discovery/src/main/java/org/springframework/cloud/consul/discovery/TtlScheduler.java
View File

@@ -57,7 +57,10 @@ public class TtlScheduler {
ScheduledFuture task = scheduler.scheduleAtFixedRate(new ConsulHeartbeatTask(
service.getId()), configuration.computeHearbeatInterval()
.toStandardDuration().getMillis());
serviceHeartbeats.put(service.getId(), task);
ScheduledFuture previousTask = serviceHeartbeats.put(service.getId(), task);
if (previousTask != null) {
previousTask.cancel(true);
}
}
public void remove(String serviceId) {