Skip to content

Commit fa5c819

Browse files
authored
Merge pull request #720 from ripienaar/trace_body
Correctly populate trace bodies when publishing
2 parents ea5c308 + bbcbf36 commit fa5c819

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

api/server/tracing/tracing.go

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -54,7 +54,10 @@ func TraceMsg(nc *nats.Conn, traceMsg *nats.Msg, deliverToDest bool, timeout tim
5454
time.Sleep(250 * time.Millisecond) // allow for super cluster propagation
5555

5656
newMsg := nats.NewMsg(traceMsg.Subject)
57+
58+
newMsg.Data = make([]byte, len(traceMsg.Data))
5759
copy(newMsg.Data, traceMsg.Data)
60+
5861
for k, vs := range traceMsg.Header {
5962
for _, v := range vs {
6063
newMsg.Header.Add(k, v)

0 commit comments

Comments
 (0)