Skip to content

Commit 0cb6b45

Browse files
gaoyfRongtongJin
authored andcommitted
[ISSUE #9294] Proxy compatible batch message (#9295)
1 parent 47fe25f commit 0cb6b45

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

proxy/src/main/java/org/apache/rocketmq/proxy/remoting/activity/AbstractRemotingActivity.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -63,7 +63,7 @@ public AbstractRemotingActivity(RequestPipeline requestPipeline, MessagingProces
6363
protected RemotingCommand request(ChannelHandlerContext ctx, RemotingCommand request,
6464
ProxyContext context, long timeoutMillis) throws Exception {
6565
String brokerName;
66-
if (request.getCode() == RequestCode.SEND_MESSAGE_V2) {
66+
if (request.getCode() == RequestCode.SEND_MESSAGE_V2 || request.getCode() == RequestCode.SEND_BATCH_MESSAGE) {
6767
if (request.getExtFields().get(BROKER_NAME_FIELD_FOR_SEND_MESSAGE_V2) == null) {
6868
return RemotingCommand.buildErrorResponse(ResponseCode.VERSION_NOT_SUPPORTED,
6969
"Request doesn't have field bname");

0 commit comments

Comments
 (0)