Skip to content

Commit

Permalink
[ISSUE #1139] should use BrokerName for send back since the StoreHost…
Browse files Browse the repository at this point in the history
… in msg may not reachable in cloud env (#1138)
  • Loading branch information
absolute8511 authored Aug 31, 2024
1 parent 0422997 commit 8cfa33a
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion consumer/push_consumer.go
Original file line number Diff line number Diff line change
Expand Up @@ -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
}
Expand Down

0 comments on commit 8cfa33a

Please sign in to comment.