[rocketmq-client-go] branch native updated: fix bugs of panic when decode MessageExt (#330)

[wenfeng]

This is an automated email from the ASF dual-hosted git repository.

wenfeng pushed a commit to branch native
in repository https://gitbox.apache.org/repos/asf/rocketmq-client-go.git


The following commit(s) were added to refs/heads/native by this push:
     new 85ee94b  fix bugs of panic when decode MessageExt (#330)
85ee94b is described below

commit 85ee94b43cef817083b63cde16c98a9ea8cc67e5
Author: wenfeng <sxian.w...@gmail.com>
AuthorDate: Wed Dec 11 19:49:16 2019 +0800

    fix bugs of panic when decode MessageExt (#330)
---
 primitive/message.go | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/primitive/message.go b/primitive/message.go
index 852e6db..7461525 100644
--- a/primitive/message.go
+++ b/primitive/message.go
@@ -242,6 +242,7 @@ func DecodeMessage(data []byte) []*MessageExt {
        count := 0
        for count < len(data) {
                msg := &MessageExt{}
+               msg.Queue = &MessageQueue{}
 
                // 1. total size
                binary.Read(buf, binary.BigEndian, &msg.StoreSize)
@@ -256,7 +257,9 @@ func DecodeMessage(data []byte) []*MessageExt {
                count += 4
 
                // 4. queueID
-               binary.Read(buf, binary.BigEndian, &msg.Queue.QueueId)
+               var qId int32
+               binary.Read(buf, binary.BigEndian, &qId)
+               msg.Queue.QueueId = int(qId)
                count += 4
 
                // 5. Flag