完成链路追踪调整

farseer-go · Dec 31, 2023 · b0bcd05 · b0bcd05
1 parent 447f32c
commit b0bcd05
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pullMessage.go b/pullMessage.go
@@ -37,7 +37,7 @@ func (receiver *subscriber) pullMessage() {
 		curQueue := receiver.queueManager.queue.Range(startIndex, pullCount).ToListAny()
 		remainingCount := receiver.queueManager.queue.Count() - endIndex
 
-		traceContext := receiver.traceManager.EntryQueueConsumer(receiver.subscribeName)
+		traceContext := receiver.traceManager.EntryQueueConsumer(receiver.queueManager.name, receiver.subscribeName)
 		// 执行客户端的消费
 		exception.Try(func() {
 			sw := stopwatch.StartNew()