You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@servicecomb.apache.org by li...@apache.org on 2018/10/23 12:50:49 UTC
[incubator-servicecomb-java-chassis] branch master updated:
[SCB-718]fix compile errors
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 064736e [SCB-718]fix compile errors
064736e is described below
commit 064736e090246d58198b1427601c2fc7372463a1
Author: liubao <ba...@huawei.com>
AuthorDate: Tue Oct 23 18:06:13 2018 +0800
[SCB-718]fix compile errors
---
.../apache/servicecomb/it/deploy/MicroserviceDeploy.java | 13 +++++++++++++
.../serviceregistry/registry/RemoteServiceRegistry.java | 1 +
2 files changed, 14 insertions(+)
diff --git a/integration-tests/it-consumer/src/main/java/org/apache/servicecomb/it/deploy/MicroserviceDeploy.java b/integration-tests/it-consumer/src/main/java/org/apache/servicecomb/it/deploy/MicroserviceDeploy.java
index 4561e81..94d1180 100644
--- a/integration-tests/it-consumer/src/main/java/org/apache/servicecomb/it/deploy/MicroserviceDeploy.java
+++ b/integration-tests/it-consumer/src/main/java/org/apache/servicecomb/it/deploy/MicroserviceDeploy.java
@@ -75,5 +75,18 @@ public class MicroserviceDeploy extends NormalDeploy {
sendCommand("ms-stop");
waitStop();
+
+ MicroserviceVersionRule microserviceVersionRule = RegistryUtils.getServiceRegistry().getAppManager()
+ .getOrCreateMicroserviceVersionRule(microserviceDeployDefinition.getAppId(),
+ microserviceDeployDefinition.getMicroserviceName(),
+ microserviceDeployDefinition.getVersion());
+ while (microserviceVersionRule.getInstances().size() > 0) {
+ try {
+ LOGGER.info("{} not stop finished wait.", microserviceDeployDefinition.getDisplayName());
+ Thread.sleep(3000);
+ } catch (InterruptedException e) {
+ e.printStackTrace();
+ }
+ }
}
}
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 f9dbb46..1dc0be8 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
@@ -25,6 +25,7 @@ import org.apache.servicecomb.serviceregistry.client.ServiceRegistryClient;
import org.apache.servicecomb.serviceregistry.client.http.ServiceRegistryClientImpl;
import org.apache.servicecomb.serviceregistry.config.ServiceRegistryConfig;
import org.apache.servicecomb.serviceregistry.definition.MicroserviceDefinition;
+import org.apache.servicecomb.serviceregistry.task.HeartbeatResult;
import org.apache.servicecomb.serviceregistry.task.MicroserviceInstanceHeartbeatTask;
import org.apache.servicecomb.serviceregistry.task.event.PeriodicPullEvent;
import org.apache.servicecomb.serviceregistry.task.event.PullMicroserviceVersionsInstancesEvent;