opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-10-25 10:03:57 +08:00
Code Issues Packages Projects Releases Wiki Activity

[ISSUE #9119] Invoke async should throw raw exception instead of CompletionException (#9120)

Browse Source
This commit is contained in:
gaoyf
2025-07-19 18:17:55 +08:00
committed by RongtongJin
parent 18a69d5169
commit 99cd998c84
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingAbstract.java
+2 -1
View File
@@ -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;
});
}