commit f525a34f6151b8ea9a91db49d3f55db636e070f8
author Lei Zhiyuan <leizhiyuan@gmail.com> Wed Feb 07 10:52:32 2024 +0800
committer GitHub <noreply@github.com> Wed Feb 07 10:52:32 2024 +0800
tree 95f3b9904ee2ece67bec8fa5df92e4222a2c44d7
parent d38558800c184ad34030388afec54715ad6784a8

[ISSUE #7813] setStartDetectorEnable Not effective

client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java

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 daab475..26e6297 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
@@ -1810,4 +1810,8 @@
     public DefaultMQProducer getDefaultMQProducer() {
         return defaultMQProducer;
     }
+
+    public MQFaultStrategy getMqFaultStrategy() {
+        return mqFaultStrategy;
+    }
 }

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

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 5d785a0..13be47c 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
@@ -1366,4 +1366,10 @@
     public void setTopics(List<String> topics) {
         this.topics = topics;
     }
+
+    @Override
+    public void setStartDetectorEnable(boolean startDetectorEnable) {
+        super.setStartDetectorEnable(startDetectorEnable);
+        this.defaultMQProducerImpl.getMqFaultStrategy().setStartDetectorEnable(startDetectorEnable);
+    }
 }