@Override
                    public Thread newThread(Runnable r) {
                        return new Thread(r, "Broker Log Mem Flush Thread");
                    }
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