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")