diff --git a/apm-sniffer/apm-sdk-plugin/vertx-plugins/vertx-core-4.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/vertx4/SWVertxTracer.java b/apm-sniffer/apm-sdk-plugin/vertx-plugins/vertx-core-4.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/vertx4/SWVertxTracer.java index aeb782a3e..b05c3ea53 100644 --- a/apm-sniffer/apm-sdk-plugin/vertx-plugins/vertx-core-4.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/vertx4/SWVertxTracer.java +++ b/apm-sniffer/apm-sdk-plugin/vertx-plugins/vertx-core-4.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/vertx4/SWVertxTracer.java @@ -127,12 +127,14 @@ public class SWVertxTracer implements VertxTracer { remotePeer = (String) enhancedInstance.getSkyWalkingDynamicField(); } } + ContextCarrier contextCarrier = new ContextCarrier(); AbstractSpan span = toExitSpan(clientRequest.address(), remotePeer, contextCarrier, context); SpanLayer.asRPCFramework(span); return toExitAsyncSpan(context, headers, contextCarrier, span); } + return null; } @@ -178,6 +180,7 @@ public class SWVertxTracer implements VertxTracer { private AbstractSpan toExitAsyncSpan(Context context, BiConsumer headers, ContextCarrier contextCarrier, AbstractSpan span) { + ContextManager.inject(contextCarrier); CarrierItem next = contextCarrier.items(); while (next.hasNext()) { next = next.next();