[rocketmq-client-go] branch master updated: [ISSUE #688] fix: type assert panic

[wenfeng]

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 2bdc662  [ISSUE #688] fix: type assert panic
2bdc662 is described below

commit 2bdc662c91c92aa0f68a90f1db5a3c4b6e677db0
Author: Berlin <fengber...@qq.com>
AuthorDate: Mon Jul 5 10:58:29 2021 +0800

    [ISSUE #688] fix: type assert panic
---
 consumer/pull_consumer.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/consumer/pull_consumer.go b/consumer/pull_consumer.go
index 3a54194..0b0ef56 100644
--- a/consumer/pull_consumer.go
+++ b/consumer/pull_consumer.go
@@ -144,7 +144,7 @@ func (c *defaultPullConsumer) getNextQueueOf(topic string) 
*primitive.MessageQue
        v, exist := queueCounterTable.Load(topic)
        if !exist {
                index = -1
-               queueCounterTable.Store(topic, 0)
+               queueCounterTable.Store(topic, int64(0))
        } else {
                index = v.(int64)
        }