This is an automated email from the ASF dual-hosted git repository. liubao pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/incubator-servicecomb-java-chassis.git
The following commit(s) were added to refs/heads/master by this push: new 8dd1f6a [SCB-401]keep pull strategy always alive whatever watch strategy state 8dd1f6a is described below commit 8dd1f6a7e259cfe88a6d3ca60eeff342818233f8 Author: m00416667 <mengt...@huawei.com> AuthorDate: Thu Mar 15 11:46:03 2018 +0800 [SCB-401]keep pull strategy always alive whatever watch strategy state --- .../serviceregistry/registry/RemoteServiceRegistry.java | 7 ++----- 1 file changed, 2 insertions(+), 5 deletions(-) diff --git a/service-registry/src/main/java/org/apache/servicecomb/serviceregistry/registry/RemoteServiceRegistry.java b/service-registry/src/main/java/org/apache/servicecomb/serviceregistry/registry/RemoteServiceRegistry.java index e8f0bf5..2a60472 100644 --- a/service-registry/src/main/java/org/apache/servicecomb/serviceregistry/registry/RemoteServiceRegistry.java +++ b/service-registry/src/main/java/org/apache/servicecomb/serviceregistry/registry/RemoteServiceRegistry.java @@ -81,19 +81,16 @@ public class RemoteServiceRegistry extends AbstractServiceRegistry { serviceRegistryConfig.getHeartbeatInterval(), serviceRegistryConfig.getHeartbeatInterval(), TimeUnit.SECONDS); - if (isNeedPull()) { + taskPool.scheduleAtFixedRate( () -> eventBus.post(new PeriodicPullEvent()), serviceRegistryConfig.getInstancePullInterval(), serviceRegistryConfig.getInstancePullInterval(), TimeUnit.SECONDS); - } - } - private boolean isNeedPull() { - return !serviceRegistryConfig.isWatch(); } + @Subscribe public void onPullMicroserviceVersionsInstancesEvent(PullMicroserviceVersionsInstancesEvent event) { taskPool.schedule(event.getMicroserviceVersions()::pullInstances, event.getMsDelay(), TimeUnit.MILLISECONDS); -- To stop receiving notification emails like this one, please contact liu...@apache.org.