(rocketmq-client-go) branch master updated: fix to#1207 (#1214)

[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 33fe267  fix to#1207 (#1214)
33fe267 is described below

commit 33fe267de2d6b78d19a189d3a59cc34cacd6ba0b
Author: fuyou001 <fuyou...@gmail.com>
AuthorDate: Thu Aug 21 20:11:09 2025 +0800

    fix to#1207 (#1214)
---
 consumer/consumer.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/consumer/consumer.go b/consumer/consumer.go
index 9e9bedb..0edeef2 100644
--- a/consumer/consumer.go
+++ b/consumer/consumer.go
@@ -578,7 +578,7 @@ func (dc *defaultConsumer) lockAll() {
                        if exist {
                                pq := v.(*processQueue)
                                pq.WithLock(true)
-                               pq.UpdateLastConsumeTime()
+                               pq.UpdateLastLockTime()
                        }
                        set[_mq] = true
                }