lizhiboo commented on a change in pull request #2684:
URL: https://github.com/apache/rocketmq/pull/2684#discussion_r579958949
##########
File path:
store/src/main/java/org/apache/rocketmq/store/schedule/ScheduleMessageService.java
##########
@@ -58,14 +59,16 @@
private final ConcurrentMap<Integer /* level */, Long/* offset */>
offsetTable =
new ConcurrentHashMap<Integer, Long>(32);
private final DefaultMessageStore defaultMessageStore;
+ private final BrokerStatsManager brokerStatsManager;
private final AtomicBoolean started = new AtomicBoolean(false);
private Timer timer;
private MessageStore writeMessageStore;
private int maxDelayLevel;
- public ScheduleMessageService(final DefaultMessageStore
defaultMessageStore) {
+ public ScheduleMessageService(final DefaultMessageStore
defaultMessageStore, final BrokerStatsManager brokerStatsManager) {
Review comment:
Add another constructor that support this feature enable system have a
better compatibility.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
