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

cserwen 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 e5b357c3df [ISSUE #5838] retry to send when broker returns SYSTEM_BUSY 
(#5845)
e5b357c3df is described below

commit e5b357c3dfd9066c6bd363e44533371d195e26e6
Author: cserwen <cser...@apache.org>
AuthorDate: Fri May 10 11:10:42 2024 +0800

    [ISSUE #5838] retry to send when broker returns SYSTEM_BUSY (#5845)
---
 .../main/java/org/apache/rocketmq/client/producer/DefaultMQProducer.java | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/client/src/main/java/org/apache/rocketmq/client/producer/DefaultMQProducer.java
 
b/client/src/main/java/org/apache/rocketmq/client/producer/DefaultMQProducer.java
index 0abf925a82..b350ba074d 100644
--- 
a/client/src/main/java/org/apache/rocketmq/client/producer/DefaultMQProducer.java
+++ 
b/client/src/main/java/org/apache/rocketmq/client/producer/DefaultMQProducer.java
@@ -72,6 +72,7 @@ public class DefaultMQProducer extends ClientConfig 
implements MQProducer {
         ResponseCode.TOPIC_NOT_EXIST,
         ResponseCode.SERVICE_NOT_AVAILABLE,
         ResponseCode.SYSTEM_ERROR,
+        ResponseCode.SYSTEM_BUSY,
         ResponseCode.NO_PERMISSION,
         ResponseCode.NO_BUYER_ID,
         ResponseCode.NOT_IN_CURRENT_UNIT

Reply via email to