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: [ISSUE #688] fix: type assert panic
Date Mon, 05 Jul 2021 02:58:59 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 2bdc662  [ISSUE #688] fix: type assert panic
2bdc662 is described below

commit 2bdc662c91c92aa0f68a90f1db5a3c4b6e677db0
Author: Berlin <fengberlin@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)
 	}

Mime
View raw message