liyinsheng created ROCKETMQ-71:
----------------------------------
Summary: remove commitlog, messagequeue bug
Key: ROCKETMQ-71
URL: https://issues.apache.org/jira/browse/ROCKETMQ-71
Project: Apache RocketMQ
Issue Type: Bug
Reporter: liyinsheng
Assignee: vongosling
there is the following code in DefaultMessageStore.java
this.scheduledExecutorService.scheduleAtFixedRate(new Runnable() {
@Override
public void run() {
DefaultMessageStore.this.cleanFilesPeriodically();
}
}, 1000 * 60, this.messageStoreConfig.getCleanResourceInterval(),
TimeUnit.MILLISECONDS);
scheduleAtFixedRate function should change to scheduleAtFixedRate because
executions will commence after {@code initialDelay} then {@code
initialDelay+period}, then {@code initialDelay + 2 * period}, and so on,that
means executions delay time should more and more longer
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
