(rocketmq-clients) branch master updated: [ISSUE #1098] [Golang] Ensure proper closure of done channel on receive message error (#1099)

[lizhanhui]

This is an automated email from the ASF dual-hosted git repository.

lizhanhui pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git


The following commit(s) were added to refs/heads/master by this push:
     new 6cc37178 [ISSUE #1098] [Golang] Ensure proper closure of done channel 
on receive message error (#1099)
6cc37178 is described below

commit 6cc37178421a7a96b2ad752d08c616a7faa49891
Author: Lei Zhiyuan <leizhiy...@gmail.com>
AuthorDate: Tue Sep 9 19:56:31 2025 +0800

    [ISSUE #1098] [Golang] Ensure proper closure of done channel on receive 
message error (#1099)
---
 golang/simple_consumer.go | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/golang/simple_consumer.go b/golang/simple_consumer.go
index 2e0d0092..2da42b13 100644
--- a/golang/simple_consumer.go
+++ b/golang/simple_consumer.go
@@ -232,6 +232,8 @@ func (sc *defaultSimpleConsumer) receiveMessage(ctx 
context.Context, request *v2
                        }
                        if err != nil {
                                sc.cli.log.Errorf("simpleConsumer recv msg 
err=%v, requestId=%s", err, utils.GetRequestID(ctx))
+                               done <- true
+                               defer close(done)
                                break
                        }
                        sugarBaseLogger.Debugf("receiveMessage response: %v", 
resp)