From 4e5a60cb62e1fcb3b72f90c9262348a37c28e61d Mon Sep 17 00:00:00 2001 From: sunhangda Date: Fri, 2 Jul 2021 15:48:46 +0800 Subject: [PATCH] [ISSUE #2442] when happening system busy, retry --- .../rocketmq/client/impl/producer/DefaultMQProducerImpl.java | 1 + 1 file changed, 1 insertion(+) diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java b/client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java index fac3ed35..6238e3e2 100644 --- a/client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java +++ b/client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java @@ -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: -- GitLab