diff --git a/trace.go b/trace.go index 7efd6653..1426e318 100644 --- a/trace.go +++ b/trace.go @@ -344,7 +344,7 @@ func (t *pubsubTracer) traceRPCMeta(rpc *RPC) *pb.TraceEvent_RPCMeta { var msgs []*pb.TraceEvent_MessageMeta for _, m := range rpc.Publish { msgs = append(msgs, &pb.TraceEvent_MessageMeta{ - MessageID: []byte(t.idGen.ID(&Message{Message: m})), + MessageID: []byte(t.idGen.RawID(m)), Topic: m.Topic, }) }