(rocketmq) branch develop updated: [ISSUE #9294] Proxy compatible batch message (#9295)

[yuzhou]

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

yuzhou pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/develop by this push:
     new 60fab89c22 [ISSUE #9294] Proxy compatible batch message (#9295)
60fab89c22 is described below

commit 60fab89c22a216de365c42238928b4da4532303d
Author: gaoyf <ga...@users.noreply.github.com>
AuthorDate: Fri Apr 11 14:37:54 2025 +0800

    [ISSUE #9294] Proxy compatible batch message (#9295)
---
 .../rocketmq/proxy/remoting/activity/AbstractRemotingActivity.java      | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/proxy/src/main/java/org/apache/rocketmq/proxy/remoting/activity/AbstractRemotingActivity.java
 
b/proxy/src/main/java/org/apache/rocketmq/proxy/remoting/activity/AbstractRemotingActivity.java
index 299d8def03..f3d8fb6e31 100644
--- 
a/proxy/src/main/java/org/apache/rocketmq/proxy/remoting/activity/AbstractRemotingActivity.java
+++ 
b/proxy/src/main/java/org/apache/rocketmq/proxy/remoting/activity/AbstractRemotingActivity.java
@@ -63,7 +63,7 @@ public abstract class AbstractRemotingActivity implements 
NettyRequestProcessor
     protected RemotingCommand request(ChannelHandlerContext ctx, 
RemotingCommand request,
         ProxyContext context, long timeoutMillis) throws Exception {
         String brokerName;
-        if (request.getCode() == RequestCode.SEND_MESSAGE_V2) {
+        if (request.getCode() == RequestCode.SEND_MESSAGE_V2 || 
request.getCode() == RequestCode.SEND_BATCH_MESSAGE) {
             if 
(request.getExtFields().get(BROKER_NAME_FIELD_FOR_SEND_MESSAGE_V2) == null) {
                 return 
RemotingCommand.buildErrorResponse(ResponseCode.VERSION_NOT_SUPPORTED,
                     "Request doesn't have field bname");