study/Spring-Cloud-Alibaba
1
0
Fork 0
mirror of https://gitee.com/mirrors/Spring-Cloud-Alibaba.git synced 2021-06-26 13:25:11 +08:00
Code Issues Releases Wiki Activity

fix

Browse Source
This commit is contained in:
yuhuangbin 2020-09-11 15:32:40 +08:00
parent fec6c6554c
commit f60cb805c8
1 changed files with 2 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
spring-cloud-alibaba-starters/spring-cloud-starter-alibaba-nacos-discovery/src/main/java/com/alibaba/cloud/nacos/discovery/NacosWatch.java
View File

@ -22,7 +22,6 @@ import java.util.Map;
import java.util.Optional; import java.util.Optional;
import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.atomic.AtomicBoolean; import java.util.concurrent.atomic.AtomicBoolean;
import java.util.concurrent.atomic.AtomicLong;
import com.alibaba.cloud.nacos.NacosDiscoveryProperties; import com.alibaba.cloud.nacos.NacosDiscoveryProperties;
import com.alibaba.cloud.nacos.NacosServiceManager; import com.alibaba.cloud.nacos.NacosServiceManager;
@ -52,8 +51,6 @@ public class NacosWatch implements ApplicationEventPublisherAware, SmartLifecycl
private final AtomicBoolean running = new AtomicBoolean(false); private final AtomicBoolean running = new AtomicBoolean(false);
private final AtomicLong nacosWatchIndex = new AtomicLong(0);
private ApplicationEventPublisher publisher; private ApplicationEventPublisher publisher;
private NacosServiceManager nacosServiceManager; private NacosServiceManager nacosServiceManager;
@ -96,9 +93,9 @@ public class NacosWatch implements ApplicationEventPublisherAware, SmartLifecycl
instances); instances);
instanceOptional.ifPresent(currentInstance -> { instanceOptional.ifPresent(currentInstance -> {
resetIfNeeded(currentInstance); resetIfNeeded(currentInstance);
publisher.publishEvent(
new HeartbeatEvent(this, currentInstance));
}); });
publisher.publishEvent(
new HeartbeatEvent(this, nacosWatchIndex.getAndIncrement()));
} }
} }
}); });