restore comment

open-telemetry · Oct 23, 2022 · 9d2cd8f · 9d2cd8f
1 parent 8d70ba3
commit 9d2cd8f
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()));