(rocketmq) branch develop updated: fix: remove wrong logic in the callback for sending messages in rpc (#9608)

[tianliuliu]

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

tianliuliu 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 f40a69f9f1 fix: remove wrong logic in the callback for sending 
messages in rpc (#9608)
f40a69f9f1 is described below

commit f40a69f9f14d5b2c4144e5288734fd0ac8dc5463
Author: hqbfz <125714719+3424672...@users.noreply.github.com>
AuthorDate: Tue Aug 12 18:51:35 2025 +0800

    fix: remove wrong logic in the callback for sending messages in rpc (#9608)
    
    Co-authored-by: hqbfzwang <hqbfzw...@tencent.com>
---
 .../apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java   | 3 ---
 .../org/apache/rocketmq/client/producer/RequestResponseFuture.java    | 4 ----
 2 files changed, 7 deletions(-)

diff --git 
a/client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java
 
b/client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java
index 4aa605821f..b54091e3ce 100644
--- 
a/client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java
+++ 
b/client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java
@@ -1626,7 +1626,6 @@ public class DefaultMQProducerImpl implements 
MQProducerInner {
                 @Override
                 public void onSuccess(SendResult sendResult) {
                     requestResponseFuture.setSendRequestOk(true);
-                    requestResponseFuture.acquireCountDownLatch();
                 }
 
                 @Override
@@ -1684,7 +1683,6 @@ public class DefaultMQProducerImpl implements 
MQProducerInner {
                 @Override
                 public void onSuccess(SendResult sendResult) {
                     requestResponseFuture.setSendRequestOk(true);
-                    requestResponseFuture.acquireCountDownLatch();
                 }
 
                 @Override
@@ -1742,7 +1740,6 @@ public class DefaultMQProducerImpl implements 
MQProducerInner {
                 @Override
                 public void onSuccess(SendResult sendResult) {
                     requestResponseFuture.setSendRequestOk(true);
-                    requestResponseFuture.acquireCountDownLatch();
                 }
 
                 @Override
diff --git 
a/client/src/main/java/org/apache/rocketmq/client/producer/RequestResponseFuture.java
 
b/client/src/main/java/org/apache/rocketmq/client/producer/RequestResponseFuture.java
index 203f92907a..e66c08fdc5 100644
--- 
a/client/src/main/java/org/apache/rocketmq/client/producer/RequestResponseFuture.java
+++ 
b/client/src/main/java/org/apache/rocketmq/client/producer/RequestResponseFuture.java
@@ -107,10 +107,6 @@ public class RequestResponseFuture {
         this.sendRequestOk = sendRequestOk;
     }
 
-    public void acquireCountDownLatch() {
-        this.countDownLatch.countDown();
-    }
-
     public Message getRequestMsg() {
         return requestMsg;
     }