[ISSUE #8998] No retry is required when the remaining time reaches ze…

…ro (#8999)
apache · Jan 6, 2025 · 0548593 · 0548593
1 parent 2538c34
commit 0548593
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java b/client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java
@@ -776,7 +776,7 @@ private void onExceptionImpl(final String brokerName,
         final DefaultMQProducerImpl producer
     ) {
         int tmp = curTimes.incrementAndGet();
-        if (needRetry && tmp <= timesTotal) {
+        if (needRetry && tmp <= timesTotal && timeoutMillis > 0) {
             String retryBrokerName = brokerName;//by default, it will send to the same broker
             if (topicPublishInfo != null) { //select one message queue accordingly, in order to determine which broker to send
                 MessageQueue mqChosen = producer.selectOneMessageQueue(topicPublishInfo, brokerName, false);