(rocketmq) branch develop updated: [ISSUE #9750] Fix NPE when isAsyncSendEnable is false (#9751)

[lizhimin]

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

lizhimin 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 4a64a5a361 [ISSUE #9750] Fix NPE when isAsyncSendEnable is false 
(#9751)
4a64a5a361 is described below

commit 4a64a5a361a5ace1a0399f2333745f4b855dcc7e
Author: rongtong <jinrongton...@mails.ucas.ac.cn>
AuthorDate: Tue Oct 14 10:12:50 2025 +0800

    [ISSUE #9750] Fix NPE when isAsyncSendEnable is false (#9751)
---
 .../java/org/apache/rocketmq/broker/processor/SendMessageProcessor.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/broker/src/main/java/org/apache/rocketmq/broker/processor/SendMessageProcessor.java
 
b/broker/src/main/java/org/apache/rocketmq/broker/processor/SendMessageProcessor.java
index 6d60290a58..eefdb85ccf 100644
--- 
a/broker/src/main/java/org/apache/rocketmq/broker/processor/SendMessageProcessor.java
+++ 
b/broker/src/main/java/org/apache/rocketmq/broker/processor/SendMessageProcessor.java
@@ -356,7 +356,7 @@ public class SendMessageProcessor extends 
AbstractSendMessageProcessor implement
             }
             handlePutMessageResult(putMessageResult, response, request, 
msgInner, responseHeader, sendMessageContext, ctx, queueIdInt, beginTimeMillis, 
mappingContext, BrokerMetricsManager.getMessageType(requestHeader));
             // record the transaction metrics
-            if (putMessageResult.getPutMessageStatus() == 
PutMessageStatus.PUT_OK && putMessageResult.getAppendMessageResult().isOk()) {
+            if (sendTransactionPrepareMessage && 
putMessageResult.getPutMessageStatus() == PutMessageStatus.PUT_OK && 
putMessageResult.getAppendMessageResult().isOk()) {
                 
this.brokerController.getTransactionalMessageService().getTransactionMetrics().addAndGet(msgInner.getProperty(MessageConst.PROPERTY_REAL_TOPIC),
 1);
             }
             sendMessageCallback.onComplete(sendMessageContext, response);