opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-09-24 16:04:00 +08:00
Code Issues Packages Projects Releases Wiki Activity

[ISSUE #2442] when happening system busy, retry

Browse Source
This commit is contained in:
sunhangda
2021-07-02 15:48:46 +08:00
parent d93dc4df41
commit 4e5a60cb62
1 changed files with 1 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java
+1
View File
@@ -633,6 +633,7 @@ public class DefaultMQProducerImpl implements MQProducerInner {
case ResponseCode.TOPIC_NOT_EXIST:
case ResponseCode.SERVICE_NOT_AVAILABLE:
case ResponseCode.SYSTEM_ERROR:
case ResponseCode.SYSTEM_BUSY:
case ResponseCode.NO_PERMISSION:
case ResponseCode.NO_BUYER_ID:
case ResponseCode.NOT_IN_CURRENT_UNIT: