Uploaded image for project: 'Apache RocketMQ'
  1. Apache RocketMQ
  2. ROCKETMQ-71

remove commitlog, messagequeue bug

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Closed
    • Major
    • Resolution: Won't Fix
    • None
    • None
    • None
    • None

    Description

      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

      Attachments

        Activity

          People

            vongosling Von Gosling
            yinsheng.li liyinsheng
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: