This is an automated email from the ASF dual-hosted git repository.
aaronai pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git
The following commit(s) were added to refs/heads/master by this push:
new d52a5d1 Golang: Fix typo (#248)
d52a5d1 is described below
commit d52a5d175e34f548d100fd8f28bb6335273099ff
Author: zzjcool <[email protected]>
AuthorDate: Mon Sep 26 09:45:52 2022 +0800
Golang: Fix typo (#248)
---
golang/producer.go | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/golang/producer.go b/golang/producer.go
index d87af44..2318baa 100644
--- a/golang/producer.go
+++ b/golang/producer.go
@@ -292,7 +292,7 @@ func (p *defaultProducer) send0(ctx context.Context, msgs
[]*UnifiedMessage, txE
pubMessages[idx] = pubMessage
}
- // check topic Name
+ // check message Type
messageType := pubMessages[0].messageType
for _, pubMessage := range pubMessages {
if pubMessage.messageType != messageType {
