This is an automated email from the ASF dual-hosted git repository.
wenfeng 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 8f75f4b [ISSEU #683]request parameter type error fix
8f75f4b is described below
commit 8f75f4b5472e6ea08fb9c1ca3647fbe4d982a95b
Author: Git_Yang <[email protected]>
AuthorDate: Thu Jul 1 20:09:52 2021 +0800
[ISSEU #683]request parameter type error fix
Signed-off-by: zhangyang <[email protected]>
---
internal/request.go | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/internal/request.go b/internal/request.go
index ed3de33..237d711 100644
--- a/internal/request.go
+++ b/internal/request.go
@@ -66,7 +66,7 @@ type SendMessageRequestHeader struct {
MaxReconsumeTimes int
Batch bool
DefaultTopic string
- DefaultTopicQueueNums string
+ DefaultTopicQueueNums int
}
func (request *SendMessageRequestHeader) Encode() map[string]string {
@@ -107,7 +107,7 @@ func (request *SendMessageRequestV2Header) Encode()
map[string]string {
maps["a"] = request.ProducerGroup
maps["b"] = request.Topic
maps["c"] = request.DefaultTopic
- maps["d"] = request.DefaultTopicQueueNums
+ maps["d"] = strconv.Itoa(request.DefaultTopicQueueNums)
maps["e"] = strconv.Itoa(request.QueueId)
maps["f"] = fmt.Sprintf("%d", request.SysFlag)
maps["g"] = strconv.FormatInt(request.BornTimestamp, 10)
