-
Notifications
You must be signed in to change notification settings - Fork 438
Closed
Labels
Description
BUG REPORT
- Please describe the issue you observed:
master code.
local cluster.
example/producer/trace/main.go
-
Please tell us about your environment:
-
Other information (e.g. detailed explanation, logs, related issues, suggestions on how to fix, etc):
see master code
rocketmq-client-go/internal/trace.go
Lines 460 to 482 in 782b09c
| var req = td.buildSendRequest(mq, msg) | |
| ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second) | |
| defer cancel() | |
| err := td.cli.InvokeAsync(ctx, addr, req, func(command *remote.RemotingCommand, e error) { | |
| resp := primitive.NewSendResult() | |
| if e != nil { | |
| rlog.Info("send trace data error.", map[string]interface{}{ | |
| "traceData": data, | |
| }) | |
| } else { | |
| td.cli.ProcessSendResponse(mq.BrokerName, command, resp, msg) | |
| rlog.Debug("send trace data success:", map[string]interface{}{ | |
| "SendResult": resp, | |
| "traceData": data, | |
| }) | |
| } | |
| }) | |
| if err != nil { | |
| rlog.Info("send trace data error when invoke", map[string]interface{}{ | |
| rlog.LogKeyUnderlayError: err, | |
| }) | |
| } | |
| } |