[servicecomb-java-chassis] branch master updated: [SCB-1812]Endpoint add new constructor to support user defined transport

[li...@apache.org]

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/servicecomb-java-chassis.git


The following commit(s) were added to refs/heads/master by this push:
     new 1daf106  [SCB-1812]Endpoint add new constructor to support user defined transport
1daf106 is described below

commit 1daf1068cb21ae15b6a772b069ba9e77119fd5d9
Author: liubao <bi...@qq.com>
AuthorDate: Mon Mar 23 09:08:51 2020 +0800

    [SCB-1812]Endpoint add new constructor to support user defined transport
---
 core/src/main/java/org/apache/servicecomb/core/Endpoint.java   |  7 +++++++
 .../test/java/org/apache/servicecomb/core/TestEndpoint.java    | 10 ++++++++++
 2 files changed, 17 insertions(+)

diff --git a/core/src/main/java/org/apache/servicecomb/core/Endpoint.java b/core/src/main/java/org/apache/servicecomb/core/Endpoint.java
index 9852aef..b432756 100644
--- a/core/src/main/java/org/apache/servicecomb/core/Endpoint.java
+++ b/core/src/main/java/org/apache/servicecomb/core/Endpoint.java
@@ -45,6 +45,13 @@ public class Endpoint {
     this.address = transport.parseAddress(this.endpoint);
   }
 
+  public Endpoint(Transport transport, String endpoint, MicroserviceInstance instance, Object address) {
+    this.transport = transport;
+    this.endpoint = endpoint;
+    this.instance = instance;
+    this.address = address;
+  }
+
   public String getEndpoint() {
     return endpoint;
   }
diff --git a/core/src/test/java/org/apache/servicecomb/core/TestEndpoint.java b/core/src/test/java/org/apache/servicecomb/core/TestEndpoint.java
index bed295d..45df567 100644
--- a/core/src/test/java/org/apache/servicecomb/core/TestEndpoint.java
+++ b/core/src/test/java/org/apache/servicecomb/core/TestEndpoint.java
@@ -17,6 +17,7 @@
 
 package org.apache.servicecomb.core;
 
+import org.apache.servicecomb.serviceregistry.api.registry.MicroserviceInstance;
 import org.junit.Assert;
 import org.junit.Test;
 
@@ -38,4 +39,13 @@ public class TestEndpoint {
     Assert.assertEquals(endpoint.getTransport(), transport);
     Assert.assertEquals(endpoint.toString(), "rest://123.6.6.6:8080");
   }
+
+  @Test
+  public void testEndpointAddressConstructor(@Mocked Transport transport, @Mocked MicroserviceInstance instance) {
+    Endpoint endpoint = new Endpoint(transport, "rest://123.6.6.6:8080", instance, "iot://123.6.6.6:8080");
+    Assert.assertEquals(endpoint.getAddress(), "iot://123.6.6.6:8080");
+    Assert.assertEquals(endpoint.getEndpoint(), "rest://123.6.6.6:8080");
+    Assert.assertEquals(endpoint.getTransport(), transport);
+    Assert.assertEquals(endpoint.toString(), "rest://123.6.6.6:8080");
+  }
 }