(rocketmq-clients) branch master updated: [Go] Re-check isCacheFull() on backoff expiry to avoid cache overflow (#1328)

[lizhimin]

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

lizhimins 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 3a8ec615 [Go] Re-check isCacheFull() on backoff expiry to avoid cache 
overflow (#1328)
3a8ec615 is described below

commit 3a8ec615c08a18d93adf564a64de37afd0cdc270
Author: Liu Shengzhong <szliu0...@gmail.com>
AuthorDate: Tue Aug 11 14:21:30 2026 +0800

    [Go] Re-check isCacheFull() on backoff expiry to avoid cache overflow 
(#1328)
---
 golang/process_queue.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/golang/process_queue.go b/golang/process_queue.go
index 7d9ce916..ccd7fee7 100644
--- a/golang/process_queue.go
+++ b/golang/process_queue.go
@@ -510,7 +510,7 @@ func (dpq *defaultProcessQueue) 
receiveMessageLater(duration time.Duration, atte
                        }
                }()
                dpq.consumer.cli.log.Infof("Try to receive message later, 
mq=%s, delay=%v, clientId=%s", dpq.mqstr, duration, dpq.consumer.cli.clientID)
-               dpq.receiveMessageImmediatelyWithAttemptId(attemptId)
+               dpq.receiveMessageWithAttemptId(attemptId)
        })
 }