[ISSUE #2588] Duplicate invoke of countdown in processReplyMessage

Co-authored-by: N yanqing.qyq <yanqing.qyq@antfin.com>

[ISSUE #2588] Duplicate invoke of countdown in processReplyMessage
Co-authored-by: N yanqing.qyq <yanqing.qyq@antfin.com>
79ed2b6f · kelvin17 · GitHub · 98aca7ff · 79ed2b6f
隐藏空白更改
内联并排

Showing with 0 addition and 2 deletion

client/src/main/java/org/apache/rocketmq/client/impl/ClientRemotingProcessor.java .../apache/rocketmq/client/impl/ClientRemotingProcessor.java +0 -2

未找到文件。
--- a/client/src/main/java/org/apache/rocketmq/client/impl/ClientRemotingProcessor.java
+++ b/client/src/main/java/org/apache/rocketmq/client/impl/ClientRemotingProcessor.java
@@ -282,8 +282,6 @@ public class ClientRemotingProcessor extends AsyncNettyRequestProcessor implemen

            if (requestResponseFuture.getRequestCallback() != null) {
                requestResponseFuture.getRequestCallback().onSuccess(replyMsg);
-            } else {
-                requestResponseFuture.putResponseMessage(replyMsg);
            }
        } else {
            String bornHost = replyMsg.getBornHostString();