rocketmq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From wenf...@apache.org
Subject [rocketmq-client-go] branch master updated: [ISSEU #683]request parameter type error fix
Date Thu, 01 Jul 2021 12:10:12 GMT
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 <30995057+Git-Yang@users.noreply.github.com>
AuthorDate: Thu Jul 1 20:09:52 2021 +0800

    [ISSEU #683]request parameter type error fix
    
    Signed-off-by: zhangyang <Git_Yang@163.com>
---
 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)

Mime
View raw message