fix(amqplib): use extracted context for message consuming

- fixes baggage propagation
open-telemetry · Jan 12, 2023 · 908cabb · 908cabb
1 parent 8b8bfeb
commit 908cabb
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/plugins/node/instrumentation-amqplib/src/amqplib.ts b/plugins/node/instrumentation-amqplib/src/amqplib.ts
@@ -451,7 +451,7 @@ export class AmqplibInstrumentation extends InstrumentationBase<typeof amqp> {
           msg[MESSAGE_STORED_SPAN] = span;
         }
 
-        context.with(trace.setSpan(context.active(), span), () => {
+        context.with(trace.setSpan(parentContext, span), () => {
           onMessage.call(this, msg);
         });