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

[we...@apache.org]

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 <fe...@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)
 	}