Skip to content

Commit 6af9de5

Browse files
author
dengzhiwen1
committed
retry to send when broker returns SYSTEM_BUSY
1 parent 0533816 commit 6af9de5

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

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

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -72,7 +72,8 @@ public class DefaultMQProducer extends ClientConfig implements MQProducer {
7272
ResponseCode.SYSTEM_ERROR,
7373
ResponseCode.NO_PERMISSION,
7474
ResponseCode.NO_BUYER_ID,
75-
ResponseCode.NOT_IN_CURRENT_UNIT
75+
ResponseCode.NOT_IN_CURRENT_UNIT,
76+
ResponseCode.SYSTEM_BUSY
7677
));
7778

7879
/**

0 commit comments

Comments
 (0)