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 b6af66b67b2..d0bd0649814 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 @@ -816,13 +816,9 @@ private SendResult sendDefaultImpl( continue; } catch (RemotingException e) { endTimestamp = System.currentTimeMillis(); - if (this.mqFaultStrategy.isStartDetectorEnable()) { - // Set this broker unreachable when detecting schedule task is running for RemotingException. - this.updateFaultItem(mq.getBrokerName(), endTimestamp - beginTimestampPrev, true, false); - } else { - // Otherwise, isolate this broker. - this.updateFaultItem(mq.getBrokerName(), endTimestamp - beginTimestampPrev, true, true); - } + // Set this broker unreachable when detecting schedule task is running for RemotingException. + // Otherwise, isolate this broker. + this.updateFaultItem(mq.getBrokerName(), endTimestamp - beginTimestampPrev, true, !this.mqFaultStrategy.isStartDetectorEnable()); log.warn("sendKernelImpl exception, resend at once, InvokeID: {}, RT: {}ms, Broker: {}", invokeID, endTimestamp - beginTimestampPrev, mq, e); if (log.isDebugEnabled()) { log.debug(msg.toString());