feat(pubsub/pstest): add Message.Topic field and populate on publish (#10510)

adzil · web-flow · commit 01bf0519093f · 2024-07-08T09:54:21.000-07:00
diff --git a/pubsub/pstest/fake.go b/pubsub/pstest/fake.go
@@ -246,6 +246,7 @@ type Message struct {
 	Acks        int      // number of acks received from clients
 	Modacks     []Modack // modacks received by server for this message
 	OrderingKey string
+	Topic       string
 
 	// protected by server mutex
 	deliveries int
@@ -828,6 +829,7 @@ func (s *GServer) Publish(_ context.Context, req *pb.PublishRequest) (*pb.Publis
 			Attributes:  pm.Attributes,
 			PublishTime: pubTime,
 			OrderingKey: pm.OrderingKey,
+			Topic:       req.Topic,
 		}
 		top.publish(pm, m)
 		ids = append(ids, id)
