fix

guyinyou · guyinyou · commit 98f73e11f4d5 · 2025-10-24T09:58:19.000+08:00
Change-Id: I73e9ecd37f25bda6d6d2f5191bd11ebb8d02c39e
diff --git a/store/src/main/java/org/apache/rocketmq/store/timer/TimerMessageStore.java b/store/src/main/java/org/apache/rocketmq/store/timer/TimerMessageStore.java
@@ -1837,10 +1837,14 @@ public void run() {
             while (!this.isStopped()) {
                 try {
                     this.flush();
-                    waitForRunning(storeConfig.getTimerFlushIntervalMs());
                 } catch (Throwable e) {
                     TimerMessageStore.LOGGER.error("Error occurred in " + getServiceName(), e);
                 }
+                try {
+                    waitForRunning(storeConfig.getTimerFlushIntervalMs());
+                } catch (Throwable e) {
+                    // ignore interrupt
+                }
             }
             TimerMessageStore.LOGGER.info(this.getServiceName() + " service end");
         }

Original file line number	Diff line number	Diff line change
`@@ -1837,10 +1837,14 @@ public void run() {`
`1837`	`1837`	`while (!this.isStopped()) {`
`1838`	`1838`	`try {`
`1839`	`1839`	`this.flush();`
`1840`		`- waitForRunning(storeConfig.getTimerFlushIntervalMs());`
`1841`	`1840`	`} catch (Throwable e) {`
`1842`	`1841`	`TimerMessageStore.LOGGER.error("Error occurred in " + getServiceName(), e);`
`1843`	`1842`	`}`
	`1843`	`+ try {`
	`1844`	`+ waitForRunning(storeConfig.getTimerFlushIntervalMs());`
	`1845`	`+ } catch (Throwable e) {`
	`1846`	`+ // ignore interrupt`
	`1847`	`+ }`
`1844`	`1848`	`}`
`1845`	`1849`	`TimerMessageStore.LOGGER.info(this.getServiceName() + " service end");`
`1846`	`1850`	`}`