Skip to content

Commit

Permalink
调整:区分Redis订阅和本地事件订阅
Browse files Browse the repository at this point in the history
  • Loading branch information
steden committed Jan 16, 2024
1 parent 68c8321 commit 192c059
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions traceManager.go
Original file line number Diff line number Diff line change
Expand Up @@ -97,7 +97,7 @@ func (*traceManager) EntryQueueConsumer(queueName, subscribeName string) trace.I
}

// EntryEventConsumer event 事件消费埋点
func (receiver *traceManager) EntryEventConsumer(eventName, subscribeName string) trace.ITraceContext {
func (receiver *traceManager) EntryEventConsumer(server, eventName, subscribeName string) trace.ITraceContext {
// 事件消费,一般是由其它入口的程序触发的,所以这里先看能不能取到之前的上下文
var traceId string
var parentAppName string
Expand All @@ -116,7 +116,7 @@ func (receiver *traceManager) EntryEventConsumer(eventName, subscribeName string
StartTs: time.Now().UnixMicro(),
TraceType: eumTraceType.EventConsumer,
ConsumerContext: ConsumerContext{
ConsumerServer: fmt.Sprintf("本地Event/%s/%s/%v", core.AppName, core.AppIp, core.AppId),
ConsumerServer: server,
ConsumerQueueName: eventName + "/" + subscribeName,
},
}
Expand Down

0 comments on commit 192c059

Please sign in to comment.