Skip to content

Commit d66cfa9

Browse files
authored
[ISSUE #10165] Prevent RocksDB metrics from being overwritten after timer engine switch (#10166)
1 parent 7d7eb73 commit d66cfa9

File tree

2 files changed

+682
-0
lines changed

2 files changed

+682
-0
lines changed

store/src/main/java/org/apache/rocketmq/store/timer/TimerMessageStore.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -526,6 +526,9 @@ public void run() {
526526
public void run() {
527527
try {
528528
if (storeConfig.isTimerEnableCheckMetrics()) {
529+
if (storeConfig.isTimerStopEnqueue()) {
530+
return;
531+
}
529532
String when = storeConfig.getTimerCheckMetricsWhen();
530533
if (!UtilAll.isItTimeToDo(when)) {
531534
return;

0 commit comments

Comments
 (0)