[ISSUE apache#5838] retry to send when broker returns SYSTEM_BUSY (ap…

…ache#5845)
Jianing-Xu · May 10, 2024 · e5b357c · e5b357c
1 parent 89c1509
commit e5b357c
Showing 1 changed file with 1 addition and 0 deletions.
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
@@ -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