[rocketmq-client-go] branch master updated: [ISSUE #975]when close consumer, return directly

[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 896a8a3  [ISSUE #975]when close consumer, return directly
896a8a3 is described below

commit 896a8a3453be4bcfcb5bfb5bb9139c4df6d4cdab
Author: wenxuwan <wangwx_junct...@163.com>
AuthorDate: Mon Dec 19 10:49:44 2022 +0800

    [ISSUE #975]when close consumer, return directly
---
 internal/trace.go | 1 +
 1 file changed, 1 insertion(+)

diff --git a/internal/trace.go b/internal/trace.go
index 891f3b6..ad30281 100644
--- a/internal/trace.go
+++ b/internal/trace.go
@@ -382,6 +382,7 @@ func (td *traceDispatcher) process() {
                                runtime.Gosched()
                        }
                        rlog.Info(fmt.Sprintf("------end trace send %v %v", 
td.input, td.batchCh), nil)
+                       return
                }
        }
 }