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 2022/07/21 12:55:20 UTC
[rocketmq-client-go] branch master updated: fix pullThresholdSizeForTopic invalid (#814)
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 d802a4d fix pullThresholdSizeForTopic invalid (#814)
d802a4d is described below
commit d802a4d434b20d67534962aa7f62f3954157a7a5
Author: hjxp <45...@users.noreply.github.com>
AuthorDate: Thu Jul 21 20:55:15 2022 +0800
fix pullThresholdSizeForTopic invalid (#814)
* fix pullThresholdSizeForTopic invalid
* fix code style
Co-authored-by: longjunhu <hu...@douyu.tv>
Co-authored-by: dinglei <li...@163.com>
---
consumer/push_consumer.go | 1 +
1 file changed, 1 insertion(+)
diff --git a/consumer/push_consumer.go b/consumer/push_consumer.go
index 9bf402b..47fe679 100644
--- a/consumer/push_consumer.go
+++ b/consumer/push_consumer.go
@@ -451,6 +451,7 @@ func (pc *pushConsumer) messageQueueChanged(topic string, mqAll, mqDivided []*pr
rlog.LogKeyValueChangedFrom: pc.option.PullThresholdSizeForTopic,
rlog.LogKeyValueChangedTo: newVal,
})
+ pc.option.PullThresholdSizeForTopic = newVal
}
}
pc.client.SendHeartbeatToAllBrokerWithLock()