@Override
    public void start() {
        try {
            this.loadMessageStores(this.tubeConfig);
        } catch (final IOException e) {
            logger.error("[Store Manager] load message stores failed", e);
            throw new StartupException("Initialize message store manager failed", e);
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }
        this.logClearScheduler.scheduleWithFixedDelay(new LogClearRunner(),
                tubeConfig.getLogClearupDurationMs(),
                tubeConfig.getLogClearupDurationMs(),
                TimeUnit.MILLISECONDS);

        this.unFlushDiskScheduler.scheduleWithFixedDelay(new DiskUnFlushRunner(),
                tubeConfig.getLogFlushDiskDurMs(),
                tubeConfig.getLogFlushDiskDurMs(),
                TimeUnit.MILLISECONDS);

        this.unFlushMemScheduler.scheduleWithFixedDelay(new MemUnFlushRunner(),
                tubeConfig.getLogFlushMemDurMs(),
                tubeConfig.getLogFlushMemDurMs(),
                TimeUnit.MILLISECONDS);

    }
Initial the message-store manager.

@param tubeBroker      the broker instance
@param tubeConfig      the initial configure
@throws IOException    the exception during processing
inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/msgstore/MessageStoreManager.java