Add constuctor of default

d510dd79 · zhangxu16 · 9eca70f5 · d510dd79
隐藏空白更改
内联并排

Showing with 6 addition and 0 deletion

store/src/main/java/org/apache/rocketmq/store/schedule/ScheduleMessageService.java ...pache/rocketmq/store/schedule/ScheduleMessageService.java +6 -0

未找到文件。
--- a/store/src/main/java/org/apache/rocketmq/store/schedule/ScheduleMessageService.java
+++ b/store/src/main/java/org/apache/rocketmq/store/schedule/ScheduleMessageService.java
@@ -65,6 +65,12 @@ public class ScheduleMessageService extends ConfigManager {
    private MessageStore writeMessageStore;
    private int maxDelayLevel;

+    public ScheduleMessageService(final DefaultMessageStore defaultMessageStore) {
+        this.defaultMessageStore = defaultMessageStore;
+        this.writeMessageStore = defaultMessageStore;
+        this.brokerStatsManager = null;
+    }
+
    public ScheduleMessageService(final DefaultMessageStore defaultMessageStore, final BrokerStatsManager brokerStatsManager) {
        this.defaultMessageStore = defaultMessageStore;
        this.writeMessageStore = defaultMessageStore;