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 <[email protected]>
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