diff --git a/traceManager.go b/traceManager.go index d35e22f..249a77a 100644 --- a/traceManager.go +++ b/traceManager.go @@ -100,12 +100,10 @@ func (*traceManager) EntryQueueConsumer(queueName, subscribeName string) trace.I func (receiver *traceManager) EntryEventConsumer(server, eventName, subscribeName string) trace.ITraceContext { // 事件消费,一般是由其它入口的程序触发的,所以这里先看能不能取到之前的上下文 var traceId string - var parentAppName string var traceLevel int if cur := receiver.GetCurTrace(); cur != nil { traceId = cur.GetTraceId() - parentAppName = core.AppName traceLevel = cur.GetTraceLevel() + 1 } else { traceId = parse.ToString(sonyflake.GenerateId()) @@ -114,7 +112,7 @@ func (receiver *traceManager) EntryEventConsumer(server, eventName, subscribeNam AppId: parse.ToString(core.AppId), AppName: core.AppName, AppIp: core.AppIp, - ParentAppName: parentAppName, + ParentAppName: "", TraceId: traceId, StartTs: time.Now().UnixMicro(), TraceType: eumTraceType.EventConsumer,