mirror of
https://github.com/apache/rocketmq.git
synced 2026-09-24 16:04:00 +08:00
fix(dledger): reload the delay offset when master changed (#2518)
This commit is contained in:
@@ -112,6 +112,7 @@ public class ScheduleMessageService extends ConfigManager {
|
||||
|
||||
public void start() {
|
||||
if (started.compareAndSet(false, true)) {
|
||||
super.load();
|
||||
this.timer = new Timer("ScheduleMessageTimerThread", true);
|
||||
for (Map.Entry<Integer, Long> entry : this.delayLevelTable.entrySet()) {
|
||||
Integer level = entry.getKey();
|
||||
|
||||
Reference in New Issue
Block a user