public void flushMemCacheData() throws IOException {
        if (this.closed.get()) {
            throw new IllegalStateException(new StringBuilder(512)
                    .append("[Data Store] Closed MessageStore for storeKey ")
                    .append(this.storeKey).toString());
        }
        if (tubeConfig.isEnableMemStore()) {
            if (msgMemStore.getCurMsgCount() > 0
                    && (System.currentTimeMillis() - this.lastMemFlushTime.get()) >= this.writeCacheFlushIntvl) {
                triggerFlushAndAddMsg(false, true, -1, 0, 0, null, 0, null, null);
            }
        }
    }
Flush memory store to file.

@throws IOException the exception during processing
inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/msgstore/MessageStore.java