From f29d1f72f89560362b5ac70a2b5203c90d08357a Mon Sep 17 00:00:00 2001 From: Brandon Fergerson Date: Sun, 6 Mar 2022 00:20:07 +0100 Subject: [PATCH] fix broken cross process (#119) --- .../org/apache/skywalking/apm/plugin/vertx4/SWVertxTracer.java | 3 +++ 1 file changed, 3 insertions(+) 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();