From 2f8e19f3ef733fa20dd95b25e993c80737ac5eda Mon Sep 17 00:00:00 2001 From: "FuCheng,Yan" Date: Sun, 14 Apr 2019 07:28:58 +0800 Subject: [PATCH] Fix create multiple EntrySpan (#2482) --- .../spring/webflux/v5/OnInboundNextInterceptor.java | 12 +++++++----- 1 file changed, 7 insertions(+), 5 deletions(-) diff --git a/apm-sniffer/apm-sdk-plugin/spring-plugins/webflux-5.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/spring/webflux/v5/OnInboundNextInterceptor.java b/apm-sniffer/apm-sdk-plugin/spring-plugins/webflux-5.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/spring/webflux/v5/OnInboundNextInterceptor.java index d439ce137..e6031f7ba 100644 --- a/apm-sniffer/apm-sdk-plugin/spring-plugins/webflux-5.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/spring/webflux/v5/OnInboundNextInterceptor.java +++ b/apm-sniffer/apm-sdk-plugin/spring-plugins/webflux-5.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/spring/webflux/v5/OnInboundNextInterceptor.java @@ -45,11 +45,13 @@ public class OnInboundNextInterceptor implements InstanceMethodsAroundIntercepto next.setHeadValue(request.headers().get(next.getHeadKey())); } - AbstractSpan span = ContextManager.createEntrySpan(request.uri(), contextCarrier); - Tags.URL.set(span, request.uri()); - Tags.HTTP.METHOD.set(span, request.method().name()); - span.setComponent(ComponentsDefine.SPRING_MVC_ANNOTATION); - SpanLayer.asHttp(span); + if (allArguments[1] instanceof HttpRequest) { + AbstractSpan span = ContextManager.createEntrySpan(request.uri(), contextCarrier); + Tags.URL.set(span, request.uri()); + Tags.HTTP.METHOD.set(span, request.method().name()); + span.setComponent(ComponentsDefine.SPRING_MVC_ANNOTATION); + SpanLayer.asHttp(span); + } } }