Skip to content

Commit f40a69f

Browse files
3424672656hqbfzwang
andauthored
fix: remove wrong logic in the callback for sending messages in rpc (#9608)
Co-authored-by: hqbfzwang <hqbfzwang@tencent.com>
1 parent c05dcdc commit f40a69f

2 files changed

Lines changed: 0 additions & 7 deletions

File tree

client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1626,7 +1626,6 @@ public Message request(final Message msg,
16261626
@Override
16271627
public void onSuccess(SendResult sendResult) {
16281628
requestResponseFuture.setSendRequestOk(true);
1629-
requestResponseFuture.acquireCountDownLatch();
16301629
}
16311630

16321631
@Override
@@ -1684,7 +1683,6 @@ public Message request(final Message msg, final MessageQueueSelector selector, f
16841683
@Override
16851684
public void onSuccess(SendResult sendResult) {
16861685
requestResponseFuture.setSendRequestOk(true);
1687-
requestResponseFuture.acquireCountDownLatch();
16881686
}
16891687

16901688
@Override
@@ -1742,7 +1740,6 @@ public Message request(final Message msg, final MessageQueue mq, final long time
17421740
@Override
17431741
public void onSuccess(SendResult sendResult) {
17441742
requestResponseFuture.setSendRequestOk(true);
1745-
requestResponseFuture.acquireCountDownLatch();
17461743
}
17471744

17481745
@Override

client/src/main/java/org/apache/rocketmq/client/producer/RequestResponseFuture.java

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -107,10 +107,6 @@ public void setSendRequestOk(boolean sendRequestOk) {
107107
this.sendRequestOk = sendRequestOk;
108108
}
109109

110-
public void acquireCountDownLatch() {
111-
this.countDownLatch.countDown();
112-
}
113-
114110
public Message getRequestMsg() {
115111
return requestMsg;
116112
}

0 commit comments

Comments
 (0)