(rocketmq) branch develop updated: [ISSUE #7813] setStartDetectorEnable Not effective

[jinrongtong]

This is an automated email from the ASF dual-hosted git repository.

jinrongtong pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/develop by this push:
     new f525a34f61 [ISSUE #7813] setStartDetectorEnable Not effective
f525a34f61 is described below

commit f525a34f6151b8ea9a91db49d3f55db636e070f8
Author: Lei Zhiyuan <leizhiy...@gmail.com>
AuthorDate: Wed Feb 7 10:52:32 2024 +0800

    [ISSUE #7813] setStartDetectorEnable Not effective
---
 .../apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java | 4 ++++
 .../java/org/apache/rocketmq/client/producer/DefaultMQProducer.java | 6 ++++++
 2 files changed, 10 insertions(+)

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 daab475fc1..26e6297a8c 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 class DefaultMQProducerImpl implements 
MQProducerInner {
     public DefaultMQProducer getDefaultMQProducer() {
         return defaultMQProducer;
     }
+
+    public MQFaultStrategy getMqFaultStrategy() {
+        return mqFaultStrategy;
+    }
 }
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 5d785a063c..13be47c79d 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 class DefaultMQProducer extends ClientConfig 
implements MQProducer {
     public void setTopics(List<String> topics) {
         this.topics = topics;
     }
+
+    @Override
+    public void setStartDetectorEnable(boolean startDetectorEnable) {
+        super.setStartDetectorEnable(startDetectorEnable);
+        
this.defaultMQProducerImpl.getMqFaultStrategy().setStartDetectorEnable(startDetectorEnable);
+    }
 }