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/06/30 03:15:04 UTC

[incubator-servicecomb-java-chassis] 01/03: [SCB-699] add schemaIds field in register.yaml when mock the Local service center

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

commit 2aee30c37e2c11a23589872cd23be61883d07a4e
Author: f00240441 <qi...@huawei.com>
AuthorDate: Tue Jun 26 19:37:20 2018 +0800

    [SCB-699] add schemaIds field in register.yaml when mock the Local service center
---
 .../serviceregistry/client/LocalServiceRegistryClientImpl.java    | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

diff --git a/service-registry/src/main/java/org/apache/servicecomb/serviceregistry/client/LocalServiceRegistryClientImpl.java b/service-registry/src/main/java/org/apache/servicecomb/serviceregistry/client/LocalServiceRegistryClientImpl.java
index 84c1516..ff3c7ea 100644
--- a/service-registry/src/main/java/org/apache/servicecomb/serviceregistry/client/LocalServiceRegistryClientImpl.java
+++ b/service-registry/src/main/java/org/apache/servicecomb/serviceregistry/client/LocalServiceRegistryClientImpl.java
@@ -118,14 +118,18 @@ public class LocalServiceRegistryClientImpl implements ServiceRegistryClient {
         String appId = (String) serviceConfig.get("appid");
         String version = (String) serviceConfig.get("version");
         String serviceId = (String) serviceConfig.get("id");
-
+        List<String> schemas = (List<String> ) serviceConfig.get("schemaIds");
+		
         Microservice microservice = new Microservice();
         microservice.setAppId(appId == null ? DEFAULT_APPLICATION_ID : appId);
         microservice.setServiceName(name);
         microservice.setVersion(version);
         microservice.setServiceId(serviceId == null ? UUID.randomUUID().toString() : serviceId);
         microserviceIdMap.put(microservice.getServiceId(), microservice);
-
+        if (schemas != null) {
+            microservice.setSchemas(schemas);
+        }
+		
         Map<String, MicroserviceInstance> instanceMap = new ConcurrentHashMap<>();
         for (Map<String, Object> instanceConfig : instancesConfig) {
           @SuppressWarnings("unchecked")