[rocketmq-client-go] branch master updated: change ConsumeGoroutineNums max value allowed (#1049)

[dinglei]

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 8c4e388  change ConsumeGoroutineNums max value allowed (#1049)
8c4e388 is described below

commit 8c4e3884d91a0a9c845e6efed3da92306f4a8cc6
Author: WeizhongTu <tuweizh...@163.com>
AuthorDate: Tue May 9 11:50:06 2023 +0800

    change ConsumeGoroutineNums max value allowed (#1049)
    
    ConsumeGoroutineNums should allow large values to be set, detail see 
https://github.com/apache/rocketmq-client-go/pull/883#issuecomment-1527143686
---
 consumer/push_consumer.go | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/consumer/push_consumer.go b/consumer/push_consumer.go
index 238ab03..50eee98 100644
--- a/consumer/push_consumer.go
+++ b/consumer/push_consumer.go
@@ -614,11 +614,11 @@ func (pc *pushConsumer) validate() error {
                }
        }
 
-       if pc.option.ConsumeGoroutineNums < 1 || pc.option.ConsumeGoroutineNums 
> 1000 {
+       if pc.option.ConsumeGoroutineNums < 1 || pc.option.ConsumeGoroutineNums 
> 100000 {
                if pc.option.ConsumeGoroutineNums == 0 {
                        pc.option.ConsumeGoroutineNums = 20
                } else {
-                       return errors.New("option.ConsumeGoroutineNums out of 
range [1, 1000]")
+                       return errors.New("option.ConsumeGoroutineNums out of 
range [1, 100000]")
                }
        }
        return nil