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 f44bcb8 feat: fix push consumer pause data race (#1219)
f44bcb8 is described below
commit f44bcb841f117e3f094bacbc7f690d41c87edafd
Author: WeizhongTu <[email protected]>
AuthorDate: Thu Sep 4 15:26:50 2025 +0800
feat: fix push consumer pause data race (#1219)
---
consumer/push_consumer.go | 1 +
1 file changed, 1 insertion(+)
diff --git a/consumer/push_consumer.go b/consumer/push_consumer.go
index 0c2a630..f6864d5 100644
--- a/consumer/push_consumer.go
+++ b/consumer/push_consumer.go
@@ -98,6 +98,7 @@ func NewPushConsumer(opts ...Option) (*pushConsumer, error) {
consumerGroup: defaultOpts.GroupName,
cType: _PushConsume,
state:
atomic.NewInt32(int32(internal.StateCreateJust)),
+ pause: atomic.NewBool(false),
prCh: make(chan PullRequest, 4),
model: defaultOpts.ConsumerModel,
consumeOrderly: defaultOpts.ConsumeOrderly,
