[skywalking] branch master updated: Miss copy response code in mesh analysis. (#2684)

[wusheng]

This is an automated email from the ASF dual-hosted git repository.

wusheng pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/skywalking.git


The following commit(s) were added to refs/heads/master by this push:
     new 3c52a32  Miss copy response code in mesh analysis. (#2684)
3c52a32 is described below

commit 3c52a326cb7429bcdc287e6cca7d26cbe7b2a353
Author: 吴晟 Wu Sheng <wu.sh...@foxmail.com>
AuthorDate: Thu May 16 00:20:18 2019 +0800

    Miss copy response code in mesh analysis. (#2684)
---
 .../skywalking/aop/server/receiver/mesh/TelemetryDataDispatcher.java  | 4 ++++
 1 file changed, 4 insertions(+)

diff --git 
a/oap-server/server-receiver-plugin/skywalking-mesh-receiver-plugin/src/main/java/org/apache/skywalking/aop/server/receiver/mesh/TelemetryDataDispatcher.java
 
b/oap-server/server-receiver-plugin/skywalking-mesh-receiver-plugin/src/main/java/org/apache/skywalking/aop/server/receiver/mesh/TelemetryDataDispatcher.java
index 5bcf54b..dbe069b 100644
--- 
a/oap-server/server-receiver-plugin/skywalking-mesh-receiver-plugin/src/main/java/org/apache/skywalking/aop/server/receiver/mesh/TelemetryDataDispatcher.java
+++ 
b/oap-server/server-receiver-plugin/skywalking-mesh-receiver-plugin/src/main/java/org/apache/skywalking/aop/server/receiver/mesh/TelemetryDataDispatcher.java
@@ -142,6 +142,7 @@ public class TelemetryDataDispatcher {
         all.setEndpointName(metrics.getEndpoint());
         all.setLatency(metrics.getLatency());
         all.setStatus(metrics.getStatus());
+        all.setResponseCode(metrics.getResponseCode());
         all.setType(protocol2Type(metrics.getProtocol()));
 
         SOURCE_RECEIVER.receive(all);
@@ -157,6 +158,7 @@ public class TelemetryDataDispatcher {
         service.setEndpointName(metrics.getEndpoint());
         service.setLatency(metrics.getLatency());
         service.setStatus(metrics.getStatus());
+        service.setResponseCode(metrics.getResponseCode());
         service.setType(protocol2Type(metrics.getProtocol()));
 
         SOURCE_RECEIVER.receive(service);
@@ -196,6 +198,7 @@ public class TelemetryDataDispatcher {
         serviceInstance.setEndpointName(metrics.getEndpoint());
         serviceInstance.setLatency(metrics.getLatency());
         serviceInstance.setStatus(metrics.getStatus());
+        serviceInstance.setResponseCode(metrics.getResponseCode());
         serviceInstance.setType(protocol2Type(metrics.getProtocol()));
 
         SOURCE_RECEIVER.receive(serviceInstance);
@@ -239,6 +242,7 @@ public class TelemetryDataDispatcher {
 
         endpoint.setLatency(metrics.getLatency());
         endpoint.setStatus(metrics.getStatus());
+        endpoint.setResponseCode(metrics.getResponseCode());
         endpoint.setType(protocol2Type(metrics.getProtocol()));
 
         SOURCE_RECEIVER.receive(endpoint);