(rocketmq) branch 4.9.x updated: fix missing brokerName in sendMessageBack request (#8606)

[lizhanhui]

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

lizhanhui pushed a commit to branch 4.9.x
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/4.9.x by this push:
     new 42c609abb1 fix missing brokerName in sendMessageBack request (#8606)
42c609abb1 is described below

commit 42c609abb192c60517e87dabd58218e7383225e4
Author: yuz10 <845238...@qq.com>
AuthorDate: Fri Aug 30 13:50:04 2024 +0800

    fix missing brokerName in sendMessageBack request (#8606)
---
 .../java/org/apache/rocketmq/client/consumer/DefaultMQPullConsumer.java | 2 +-
 .../java/org/apache/rocketmq/client/consumer/DefaultMQPushConsumer.java | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPullConsumer.java
 
b/client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPullConsumer.java
index 206ee660e6..e8dcea9700 100644
--- 
a/client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPullConsumer.java
+++ 
b/client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPullConsumer.java
@@ -272,7 +272,7 @@ public class DefaultMQPullConsumer extends ClientConfig 
implements MQPullConsume
     public void sendMessageBack(MessageExt msg, int delayLevel)
         throws RemotingException, MQBrokerException, InterruptedException, 
MQClientException {
         msg.setTopic(withNamespace(msg.getTopic()));
-        this.defaultMQPullConsumerImpl.sendMessageBack(msg, delayLevel, null);
+        this.defaultMQPullConsumerImpl.sendMessageBack(msg, delayLevel, 
msg.getBrokerName());
     }
 
     /**
diff --git 
a/client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPushConsumer.java
 
b/client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPushConsumer.java
index d8dbe5a197..e7de117762 100644
--- 
a/client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPushConsumer.java
+++ 
b/client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPushConsumer.java
@@ -657,7 +657,7 @@ public class DefaultMQPushConsumer extends ClientConfig 
implements MQPushConsume
     public void sendMessageBack(MessageExt msg, int delayLevel)
         throws RemotingException, MQBrokerException, InterruptedException, 
MQClientException {
         msg.setTopic(withNamespace(msg.getTopic()));
-        this.defaultMQPushConsumerImpl.sendMessageBack(msg, delayLevel, null);
+        this.defaultMQPushConsumerImpl.sendMessageBack(msg, delayLevel, 
msg.getBrokerName());
     }
 
     /**