(rocketmq-client-go) branch master updated: [ISSUE #1139] should use BrokerName for send back since the StoreHost in msg may not reachable in cloud env (#1138)

[yuzhou]

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

yuzhou 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 8cfa33a  [ISSUE #1139] should use BrokerName for send back since the 
StoreHost in msg may not reachable in cloud env (#1138)
8cfa33a is described below

commit 8cfa33a401955950155c24732d4e00c8f41e2174
Author: Vincent Lee <cool8...@gmail.com>
AuthorDate: Sat Aug 31 15:23:05 2024 +0800

    [ISSUE #1139] should use BrokerName for send back since the StoreHost in 
msg may not reachable in cloud env (#1138)
---
 consumer/push_consumer.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/consumer/push_consumer.go b/consumer/push_consumer.go
index 259980a..0dfeee9 100644
--- a/consumer/push_consumer.go
+++ b/consumer/push_consumer.go
@@ -1376,7 +1376,7 @@ func (pc *pushConsumer) checkReconsumeTimes(msgs 
[]*primitive.MessageExt) bool {
                        if msg.ReconsumeTimes > maxReconsumeTimes {
                                rlog.Warning(fmt.Sprintf("msg will be send to 
retry topic due to ReconsumeTimes > %d, \n", maxReconsumeTimes), nil)
                                msg.WithProperty("RECONSUME_TIME", 
strconv.Itoa(int(msg.ReconsumeTimes)))
-                               if !pc.sendMessageBack("", msg, -1) {
+                               if !pc.sendMessageBack(msg.Queue.BrokerName, 
msg, -1) {
                                        suspend = true
                                        msg.ReconsumeTimes += 1
                                }