This is an automated email from the ASF dual-hosted git repository.
jinrongtong 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 40f5d5e3 golang: compatible with some abnormal scenarios, such as
flowlimit
40f5d5e3 is described below
commit 40f5d5e38149d00f4629beb5d709be724f96fa6c
Author: guyinyou <[email protected]>
AuthorDate: Thu Jul 3 11:03:02 2025 +0800
golang: compatible with some abnormal scenarios, such as flowlimit
compatible with some abnormal scenarios, such as flowlimit
Co-authored-by: guyinyou <[email protected]>
---
golang/push_consumer.go | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/golang/push_consumer.go b/golang/push_consumer.go
index 5833f17b..5fa9f169 100644
--- a/golang/push_consumer.go
+++ b/golang/push_consumer.go
@@ -128,7 +128,7 @@ func (pc *defaultPushConsumer)
changeInvisibleDuration(messageView *MessageView,
return fmt.Errorf("changeInvisibleDuration failed, err = the
message is nil")
}
resp, err := pc.changeInvisibleDuration0(context.Background(),
messageView, invisibleDuration)
- if resp != nil {
+ if err == nil && resp != nil {
messageView.ReceiptHandle = resp.ReceiptHandle
}
return err
