From 3c52a326cb7429bcdc287e6cca7d26cbe7b2a353 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=90=B4=E6=99=9F=20Wu=20Sheng?= Date: Thu, 16 May 2019 00:20:18 +0800 Subject: [PATCH] Miss copy response code in mesh analysis. (#2684) --- .../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 5bcf54b85..dbe069b42 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);