(rocketmq) branch develop updated: [ISSUE #9119] Invoke async should throw raw exception instead of CompletionException (#9120)

[jinrongtong]

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

jinrongtong 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 de4e48d28a [ISSUE #9119] Invoke async should throw raw exception 
instead of CompletionException (#9120)
de4e48d28a is described below

commit de4e48d28acf549c0d83fed8c0b39e13e9fa82fa
Author: gaoyf <ga...@users.noreply.github.com>
AuthorDate: Fri Jan 17 11:44:32 2025 +0800

    [ISSUE #9119] Invoke async should throw raw exception instead of 
CompletionException (#9120)
---
 .../java/org/apache/rocketmq/remoting/netty/NettyRemotingAbstract.java | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingAbstract.java
 
b/remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingAbstract.java
index 3d4e62f943..d3f5a88cf2 100644
--- 
a/remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingAbstract.java
+++ 
b/remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingAbstract.java
@@ -49,6 +49,7 @@ import org.apache.rocketmq.common.Pair;
 import org.apache.rocketmq.common.ServiceThread;
 import org.apache.rocketmq.common.UtilAll;
 import org.apache.rocketmq.common.constant.LoggerName;
+import org.apache.rocketmq.common.utils.ExceptionUtils;
 import org.apache.rocketmq.logging.org.slf4j.Logger;
 import org.apache.rocketmq.logging.org.slf4j.LoggerFactory;
 import org.apache.rocketmq.remoting.ChannelEventListener;
@@ -602,7 +603,7 @@ public abstract class NettyRemotingAbstract {
             })
             .thenAccept(responseFuture -> 
invokeCallback.operationSucceed(responseFuture.getResponseCommand()))
             .exceptionally(t -> {
-                invokeCallback.operationFail(t);
+                
invokeCallback.operationFail(ExceptionUtils.getRealException(t));
                 return null;
             });
     }