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