This is an automated email from the ASF dual-hosted git repository. wusheng pushed a commit to branch mesh-receiver in repository https://gitbox.apache.org/repos/asf/incubator-skywalking.git
commit a6fbbfe3124196408f4398b677d1160617f580ae Author: Wu Sheng <[email protected]> AuthorDate: Mon Oct 22 11:08:31 2018 +0800 Make receiver more effective --- .../aop/server/receiver/mesh/TelemetryDataDispatcher.java | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) 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 4dfcc4e..a56260a 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 @@ -59,7 +59,12 @@ public class TelemetryDataDispatcher { } public static void preProcess(ServiceMeshMetric data) { - CACHE.in(data); + ServiceMeshMetricDataDecorator decorator = new ServiceMeshMetricDataDecorator(data); + if (decorator.tryMetaDataRegister()) { + TelemetryDataDispatcher.doDispatch(decorator); + } else { + CACHE.in(data); + } } /**
