populate receivedFrom field in delivery trace

2020-12-16 19:13:26 +02:00 · 2020-12-16 19:13:26 +02:00 · 352c6b993e
parent 4f972a14dd
commit 352c6b993e
1 changed files with 3 additions and 2 deletions
--- a/trace.go
+++ b/trace.go
@ -156,6 +156,7 @@ func (t *pubsubTracer) DeliverMessage(msg *Message) {
 		DeliverMessage: &pb.TraceEvent_DeliverMessage{
 			MessageID:    []byte(t.msgID(msg.Message)),
 			Topic:        msg.Topic,
+			ReceivedFrom: []byte(msg.ReceivedFrom),
 		},
 	}