You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by di...@apache.org on 2025/10/24 01:59:34 UTC
(rocketmq-client-go) branch master updated: feat: Add pause initialization to default PullConsumer to prevent panic (#1226)
This is an automated email from the ASF dual-hosted git repository.
dinglei 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 3010ce9 feat: Add pause initialization to default PullConsumer to prevent panic (#1226)
3010ce9 is described below
commit 3010ce94c06f4cef7ec9d805e2daed744d9fe7f7
Author: wenxuwan <wa...@alibaba-inc.com>
AuthorDate: Fri Oct 24 09:59:28 2025 +0800
feat: Add pause initialization to default PullConsumer to prevent panic (#1226)
* fix pull consumer panic
---------
Co-authored-by: 文徐 <wa...@antgroup.com>
---
consumer/pull_consumer.go | 1 +
1 file changed, 1 insertion(+)
diff --git a/consumer/pull_consumer.go b/consumer/pull_consumer.go
index c6af4f7..5fc747d 100644
--- a/consumer/pull_consumer.go
+++ b/consumer/pull_consumer.go
@@ -113,6 +113,7 @@ func NewPullConsumer(options ...Option) (*defaultPullConsumer, error) {
consumerGroup: utils.WrapNamespace(defaultOpts.Namespace, defaultOpts.GroupName),
cType: _PullConsume,
state: atomic2.NewInt32(int32(internal.StateCreateJust)),
+ pause: atomic2.NewBool(false),
prCh: make(chan PullRequest, 4),
model: defaultOpts.ConsumerModel,
option: defaultOpts,