search

apache / rocketmq-client-go

Apache RocketMQ go client
https://rocketmq.apache.org/
Apache License 2.0
1.28k stars 409 forks source link

fix PullThresholdForQueue and PullThresholdSizeForQueue update #1140

Closed wenxuwan closed 3 months ago

wenxuwan commented 3 months ago

What is the purpose of the change

update PullThresholdForQueue and PullThresholdSizeForQueue when queue info change

twz915 commented 3 months ago

LGTM