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 <[email protected]>
AuthorDate: Thu Jul 21 20:55:15 2022 +0800
fix pullThresholdSizeForTopic invalid (#814)
* fix pullThresholdSizeForTopic invalid
* fix code style
Co-authored-by: longjunhu <[email protected]>
Co-authored-by: dinglei <[email protected]>
---
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()
