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

Merge pull request #241 from lowzj/TtlScheduler

Browse Source 
cancel the previous ttl task when putting a new task with the same serviceId
This commit is contained in:
Spencer Gibb
2016-11-02 15:29:21 -04:00
committed by GitHub
parent ab89d06586 0605ce71a6
commit 2e5d2b0d5e
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) {