This is an automated email from the ASF dual-hosted git repository.
cserwen pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-client-go.git
The following commit(s) were added to refs/heads/master by this push:
new d5f5776 fix can't send batch message error (#1040)
d5f5776 is described below
commit d5f5776ed7ced6d1df3763ed0014e84078a0706b
Author: tiger lee <francislee...@outlook.com>
AuthorDate: Thu Apr 27 17:36:43 2023 +0800
fix can't send batch message error (#1040)
---
producer/producer.go | 22 ++++++++++++----------
1 file changed, 12 insertions(+), 10 deletions(-)
diff --git a/producer/producer.go b/producer/producer.go
index 5586846..ebd5e33 100644
--- a/producer/producer.go
+++ b/producer/producer.go
@@ -492,16 +492,18 @@ func (p *defaultProducer) buildSendRequest(mq
*primitive.MessageQueue,
}
req := &internal.SendMessageRequestHeader{
- ProducerGroup: p.group,
- Topic: mq.Topic,
- QueueId: mq.QueueId,
- SysFlag: sysFlag,
- BornTimestamp: time.Now().UnixNano() / int64(time.Millisecond),
- Flag: msg.Flag,
- Properties: msg.MarshallProperties(),
- ReconsumeTimes: 0,
- UnitMode: p.options.UnitMode,
- Batch: msg.Batch,
+ ProducerGroup: p.group,
+ Topic: mq.Topic,
+ QueueId: mq.QueueId,
+ SysFlag: sysFlag,
+ BornTimestamp: time.Now().UnixNano() /
int64(time.Millisecond),
+ Flag: msg.Flag,
+ Properties: msg.MarshallProperties(),
+ ReconsumeTimes: 0,
+ UnitMode: p.options.UnitMode,
+ Batch: msg.Batch,
+ DefaultTopic: p.options.CreateTopicKey,
+ DefaultTopicQueueNums: p.options.DefaultTopicQueueNums,
}
msgType := msg.GetProperty(primitive.PropertyMsgType)
