ref(js): Simplify manual queue instrumentation code (#11406)

* ref(js): Simplify manual queue instrumentation code * add Sentry
getsentry · Oct 7, 2024 · f87b887 · f87b887
1 parent 67eb973
commit f87b887
Showing 1 changed file with 6 additions and 6 deletions.
diff --git a/...ascript/common/tracing/instrumentation/custom-instrumentation/queues-module.mdx b/...ascript/common/tracing/instrumentation/custom-instrumentation/queues-module.mdx
@@ -57,14 +57,14 @@ app.post("/publish", async (req, res) => {
         "messaging.message.body.size": messageBodySize,
       },
     },
-    async (span) => {
-      const traceHeader = Sentry.spanToTraceHeader(span);
-      const baggageHeader = Sentry.spanToBaggageHeader(span);
+    async () => {
+      const { "sentry-trace": sentryTrace, baggage: sentryBaggage } =
+        Sentry.getTraceData();
       await redisClient.lPush(
         "messages",
         JSON.stringify({
-          traceHeader,
-          baggageHeader,
+          sentryTrace,
+          sentryBaggage,
           timestamp: Date.now(),
           messageId,
         })
@@ -99,7 +99,7 @@ const message = JSON.parse(await redisClient.lPop(QUEUE_KEY));
 const latency = Date.now() - message.timestamp;
 
 Sentry.continueTrace(
-    { sentryTrace: message.traceHeader, baggage: message.baggageHeader },
+    { sentryTrace: message.sentryTrace, baggage: message.sentryBaggage },
     () => {
         Sentry.startSpan({
                 name: 'queue_consumer_transaction',