Skip to content

Commit f525a34

Browse files
authored
[ISSUE #7813] setStartDetectorEnable Not effective
1 parent d385588 commit f525a34

File tree

2 files changed

+10
-0
lines changed

2 files changed

+10
-0
lines changed

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

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1810,4 +1810,8 @@ public void setSendLatencyFaultEnable(final boolean sendLatencyFaultEnable) {
18101810
public DefaultMQProducer getDefaultMQProducer() {
18111811
return defaultMQProducer;
18121812
}
1813+
1814+
public MQFaultStrategy getMqFaultStrategy() {
1815+
return mqFaultStrategy;
1816+
}
18131817
}

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

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1366,4 +1366,10 @@ public List<String> getTopics() {
13661366
public void setTopics(List<String> topics) {
13671367
this.topics = topics;
13681368
}
1369+
1370+
@Override
1371+
public void setStartDetectorEnable(boolean startDetectorEnable) {
1372+
super.setStartDetectorEnable(startDetectorEnable);
1373+
this.defaultMQProducerImpl.getMqFaultStrategy().setStartDetectorEnable(startDetectorEnable);
1374+
}
13691375
}

0 commit comments

Comments
 (0)