You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by ti...@apache.org on 2025/08/12 10:51:40 UTC
(rocketmq) branch develop updated: fix: remove wrong logic in the callback for sending messages in rpc (#9608)
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 <12...@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 <hq...@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;
}