restore comment

open-telemetry · Oct 23, 2022 · c9ebbc1 · c9ebbc1
1 parent 663f4a0
commit c9ebbc1
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/...a/io/opentelemetry/instrumentation/rocketmqclient/v4_8/TracingConsumeMessageHookImpl.java b/...a/io/opentelemetry/instrumentation/rocketmqclient/v4_8/TracingConsumeMessageHookImpl.java
@@ -34,6 +34,10 @@ public void consumeMessageBefore(ConsumeMessageContext context) {
     Context parentContext = Context.current();
     Context newContext = instrumenter.start(parentContext, context.getMsgList());
 
+    // it's safe to store the scope in the rocketMq message context, both before() and after()
+    // methods are always called from the same thread; see:
+    // - ConsumeMessageConcurrentlyService$ConsumeRequest#run()
+    // - ConsumeMessageOrderlyService$ConsumeRequest#run()
     if (newContext != parentContext) {
       contextAndScopeField.set(
           context, ContextAndScope.create(newContext, newContext.makeCurrent()));