[rocketmq-client-go] branch master updated: fix consumer doesn't consume message because of blocked on Lock in some case (#898)

[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 ced8ba7  fix consumer doesn't consume message because of blocked on 
Lock in some case (#898)
ced8ba7 is described below

commit ced8ba73b35e467d584c86bf9530fcdbac2f2483
Author: givemeafish <981819...@qq.com>
AuthorDate: Mon Aug 22 17:06:59 2022 +0800

    fix consumer doesn't consume message because of blocked on Lock in some 
case (#898)
---
 consumer/process_queue.go | 1 +
 1 file changed, 1 insertion(+)

diff --git a/consumer/process_queue.go b/consumer/process_queue.go
index 92a82a3..2d35c07 100644
--- a/consumer/process_queue.go
+++ b/consumer/process_queue.go
@@ -104,6 +104,7 @@ func (pq *processQueue) putMessage(messages 
...*primitive.MessageExt) {
        if !pq.order {
                select {
                case <-pq.closeChan:
+                       pq.mutex.Unlock()
                        return
                case pq.msgCh <- messages:
                }