(rocketmq) branch develop updated: [ISSUE #9732] Fix request may still be invoked when local process timeout (#9733)

[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 64999c12bb [ISSUE #9732] Fix request may still be invoked when local 
process timeout (#9733)
64999c12bb is described below

commit 64999c12bb14bd0b3190630826920aebeaa23914
Author: qianye <wuxingcan....@alibaba-inc.com>
AuthorDate: Thu Sep 25 15:42:30 2025 +0800

    [ISSUE #9732] Fix request may still be invoked when local process timeout 
(#9733)
---
 .../java/org/apache/rocketmq/remoting/netty/NettyRemotingClient.java     | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingClient.java
 
b/remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingClient.java
index 5dcc346ef5..973d229bef 100644
--- 
a/remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingClient.java
+++ 
b/remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingClient.java
@@ -746,6 +746,7 @@ public class NettyRemotingClient extends 
NettyRemotingAbstract implements Remoti
                     long costTime = System.currentTimeMillis() - 
beginStartTime;
                     if (timeoutMillis < costTime) {
                         invokeCallback.operationFail(new 
RemotingTooMuchRequestException("invokeAsync call the addr[" + 
channelRemoteAddr + "] timeout"));
+                        return;
                     }
                     this.invokeAsyncImpl(channel, request, timeoutMillis - 
costTime, new InvokeCallbackWrapper(invokeCallback, addr));
                 } else {