passing along publisher name

This commit is contained in:
chrislu
2024-05-29 23:31:48 -07:00
parent f0b9e163a0
commit f8a22038c5
3 changed files with 290 additions and 289 deletions

View File

@@ -51,6 +51,7 @@ func (p *TopicPublisher) FinishPublish() error {
TsNs: time.Now().UnixNano(),
Ctrl: &mq_pb.ControlMessage{
IsClose: true,
PublisherName: p.config.PublisherName,
},
})
}